19.3. 检查 Kafka 重启

流程

1. 获取 Cluster Operator 发送的所有重启事件：

   oc -n kafka get events --field-selector reportingController=strimzi.io/cluster-operator

   Copy to Clipboard Toggle word wrap

   显示返回的事件示例

   LAST SEEN   TYPE     REASON                   OBJECT                        MESSAGE
   2m          Normal   CaCertRenewed            pod/strimzi-cluster-kafka-0   CA certificate renewed
   58m         Normal   PodForceRestartOnError   pod/strimzi-cluster-kafka-1   Pod needs to be forcibly restarted due to an error
   5m47s       Normal   ManualRollingUpdate      pod/strimzi-cluster-kafka-2   Pod was manually annotated to be rolled

   Copy to Clipboard Toggle word wrap

   您还可以指定 reason 或其他 field-selector 选项来限制返回的事件。

   在这里添加了一个特定原因：

   oc -n kafka get events --field-selector reportingController=strimzi.io/cluster-operator,reason=PodForceRestartOnError

   Copy to Clipboard Toggle word wrap

2. 使用输出格式（如 YAML）返回一个或多个事件的详细信息。

   oc -n kafka get events --field-selector reportingController=strimzi.io/cluster-operator,reason=PodForceRestartOnError -o yaml

   Copy to Clipboard Toggle word wrap

   显示详细事件输出的示例

   apiVersion: v1
   items:
   - action: StrimziInitiatedPodRestart
     apiVersion: v1
     eventTime: "2022-05-13T00:22:34.168086Z"
     firstTimestamp: null
     involvedObject:
         kind: Pod
         name: strimzi-cluster-kafka-1
         namespace: kafka
     kind: Event
     lastTimestamp: null
     message: Pod needs to be forcibly restarted due to an error
     metadata:
         creationTimestamp: "2022-05-13T00:22:34Z"
         generateName: strimzi-event
         name: strimzi-eventwppk6
         namespace: kafka
         resourceVersion: "432961"
         uid: 29fcdb9e-f2cf-4c95-a165-a5efcd48edfc
     reason: PodForceRestartOnError
     reportingController: strimzi.io/cluster-operator
     reportingInstance: strimzi-cluster-operator-6458cfb4c6-6bpdp
     source: {}
     type: Normal
   kind: List
   metadata:
     resourceVersion: ""
     selfLink: ""

   Copy to Clipboard Toggle word wrap