1.6. コネクターの自動再起動
新しい設定プロパティーにより、Kafka Connect および Kafka MirrorMaker 2 の失敗したコネクターとタスクの自動再起動が可能になります。autoRestart プロパティーが true に設定されている場合は最大 7 回の再起動が試行され、その後は手動で再起動する必要があります。
Kafka Connect コネクターの場合は、KafkaConnector カスタムリソースで autoRestart プロパティーを設定します。
自動再起動が有効になっている Kafka Connect 設定の例
apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaConnector
metadata:
name: my-source-connector
labels:
strimzi.io/cluster: my-connect-cluster
spec:
class: org.apache.kafka.connect.file.FileStreamSourceConnector
tasksMax: 2
autoRestart:
enabled: true
config:
file: "/opt/kafka/LICENSE"
topic: my-topic
# ...
MirrorMaker 2 コネクターの場合は、KafkaMirrorMaker2 カスタムリソースで autoRestart プロパティーを設定します。MirrorMaker 2 で使用される各内部コネクター (sourceConnector、heartbeatConnector、および checkpointConnector) の自動再起動を有効にできます。
自動再起動が有効になっている MirrorMaker 2 設定の例
apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaMirrorMaker2
metadata:
name: my-mm2-cluster
spec:
mirrors:
- sourceConnector:
autoRestart:
enabled: true
# ...
heartbeatConnector:
autoRestart:
enabled: true
# ...
checkpointConnector:
autoRestart:
enabled: true
# ...
AutoRestart スキーマのプロパティー を参照してください。