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"