kafka-console-consumer komutu

Giriş

Topic'i dinleyerek gelen mesajları gösterir

--consumer.config seçeneği

Örnek

Şöyle yaparız

bin/kafka-console-consumer.sh 
  --bootstrap-server $brokerssasl 
  --topic test 
  --consumer.config /path/to/client.properties 
  --from-beginning

--from-beginning seçeneği

Örnek

Şöyle yaparız

$ bin/kafka-console-consumer.sh --topic azure-events --from-beginning 
  --bootstrap-server localhost:9092

Örnek

Şöyle yaparız

kafka-console-consumer --bootstrap-server kafka:9092 
  --from-beginning --topic dbserver1.public.transaction 
  --property print.key=true --property key.separator="-"

--key-deserializer seçeneği

Açıklaması şöyle

The default format expected for keys and values by the plain console consumer is the String type. If the keys or values are not strings, you’ll need to provide the deserializers via the command-line flags --key-deserializer and --value-deserializer with the fully qualified class names of the respective deserializers.

--property seçeneği

- key.separator

- print.key

- print.partition

- print.timestamp

gibi bir sürü şey verilebilir.

print.key seçeneği

Örnek

Açıklaması şöyle

... by default, the console consumer only prints the value component of the messages to the screen. If you want to see the keys as well, you can do so by including the necessary flags below

Şöyle yaparız

kafka-console-consumer --topic  <topic-name> 
                       --bootstrap-server <broker-host:port> \
--property print.key=true
--property key.separator=":"

print.timestamp seçeneği

Örnek

Şöyle yaparız

kafka-console-consumer.sh --bootstrap-server localhost:9092 \
  --property print.key=true \
  --property print.timestamp=true \
  --property print.partition=true \
  --property key.separator='::' \
  --topic topicxx \
  --from-beginning > /tmp/topicxx.txt

Çıktı olarak şunu alırız

CreateTime:1637768143839::Partition:2::KEY1::VALUE1
CreateTime:1637768153839::Partition:0::KEY2::VALUE1
CreateTime:1637768163339::Partition:2::KEY1::null
CreateTime:1637768163839::Partition:2::KEY1::VALUE2

--topic seçeneği

Örnek

good_topic kuyruğundan mesaj okumak için şöyle yaparız.

bin/kafka-console-consumer.sh  --bootstrap-server host1:9092,host2:9092,host3:9092 
  --topic good_topic

test kuyruğundan mesaj okumak için şöyle yaparız.

kafka-console-consumer.bat --zookeeper localhost:2181 --topic test