Zenn
Open1

よく使うKafkaコマンド集

Apache Kafka
harrythecodeharrythecode

何する？

よく使うKafkaコマンド集です。

topicを生成したい

  • 既存/新規のtopicにmessageを書き込む (Ctrl + cで中断、送信)
kafka-console-producer.sh --bootstrap-server localhost:9092 --topic myTopic

>hej,aaa
>vvv,bbb
>^C

既存のtopicを参照・変更したい

  • 既存のtopicを参照
kafka-configs.sh --bootstrap-server localhost:9092 --entity-type topics --entity-name myTopic --all --describe

  compression.type=producer sensitive=false synonyms={DEFAULT_CONFIG:compression.type=producer}
  leader.replication.throttled.replicas= sensitive=false synonyms={}
  min.insync.replicas=1 sensitive=false synonyms={DEFAULT_CONFIG:min.insync.replicas=1}
  message.downconversion.enable=true sensitive=false synonyms={DEFAULT_CONFIG:log.message.downconversion.enable=true}
  segment.jitter.ms=0 sensitive=false synonyms={}
  cleanup.policy=compact sensitive=false synonym...
  • cleanup.policy を compact から delete に変更
kafka-configs.sh --bootstrap-server localhost:9092 --entity-type topics --entity-name myTopic --alter --add-config cleanup.policy=delete