apiVersion: litmuschaos.io/v1alpha1 kind: ChaosEngine metadata: name: kafka-chaos namespace: default spec: # It can be true/false annotationCheck: 'true' # It can be active/stop engineState: 'active' #ex. values: ns1:name=percona,ns2:run=nginx auxiliaryAppInfo: '' appinfo: appns: 'default' applabel: 'app=cp-kafka' appkind: 'statefulset' chaosServiceAccount: kafka-broker-pod-failure-sa monitoring: false # It can be delete/retain jobCleanUpPolicy: 'delete' experiments: - name: kafka-broker-pod-failure spec: components: env: # choose based on available kafka broker replicas - name: KAFKA_REPLICATION_FACTOR value: '3' # get via 'kubectl get pods --show-labels -n ' - name: KAFKA_LABEL value: 'app=cp-kafka' - name: KAFKA_NAMESPACE value: 'default' # get via 'kubectl get svc -n ' - name: KAFKA_SERVICE value: 'kafka-cp-kafka-headless' # get via 'kubectl get svc -n ' - name: KAFKA_PORT value: '9092' # in milliseconds - name: KAFKA_CONSUMER_TIMEOUT value: '70000' # ensure to set the instance name if using KUDO operator - name: KAFKA_INSTANCE_NAME value: '' - name: ZOOKEEPER_NAMESPACE value: 'default' # get via 'kubectl get pods --show-labels -n ' - name: ZOOKEEPER_LABEL value: 'app=cp-zookeeper' # get via 'kubectl get svc -n - name: ZOOKEEPER_SERVICE value: 'kafka-cp-zookeeper-headless' # get via 'kubectl get svc -n - name: ZOOKEEPER_PORT value: '2181' # set chaos duration (in sec) as desired - name: TOTAL_CHAOS_DURATION value: '60' # set chaos interval (in sec) as desired - name: CHAOS_INTERVAL value: '20' # pod failures without '--force' & default terminationGracePeriodSeconds - name: FORCE value: 'false'