私はKafkaトピックを作成するためにAnsibleスクリプトを使用します。Ansibleで2つのリストを扱うにはどうすればいいですか?
topics:
topic1:
partitions: 1
replication_factor: 2
topic2:
partitions: 1
replication_factor: 2
トピックを作成する前に、まずトピックが存在するかどうかを確認する必要があります。 kafka-topics.sh --list --zookeeper localhost:2181
を使用して既存のトピック名のリストを取得し、次にtopics
ハッシュと比較して作成するトピックのリストを取得してから、kafka-topics.sh --create --topic name
を呼び出してトピックを作成します。
これを実装する方法は?