Home Kafka Command
Post
Cancel

Kafka Command

kafka console consumer에서 custom deserializer 설정해서 record 읽기

1
2
3
4
bin/kafka-console-consumer.sh --topic number-of-people-by-place --bootstrap-server localhost:9092 \
 --from-beginning \
 --property print.key=true \
 --property key.separator=" : "  --key-deserializer "org.apache.kafka.common.serialization.IntegerDeserializer" \  --value-deserializer "org.apache.kafka.common.serialization.IntegerDeserializer"
This post is licensed under CC BY 4.0 by the author.

Trending Tags