我已经在Kafka Broker上发布了几个CNCF CloudEvents。我正在尝试使用以下命令直接在代理上查看它们:
kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic flink-test --from-beginning
我无法查看任何数据。我从来没有在使用其他序列化格式时遇到过这个问题。有人有什么想法吗?
发布于 2019-03-07 12:12:27
我认为,您应该在向代理发送消息时使用的命令中包含key.deserializer和value.deserializer。
示例:
kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic flink-test --from-beginning
--属性key.deserializer=org.apache.kafka.common.serialization.StringDeserializer
--属性value.deserializer=org.apache.kafka.common.serialization.LongDeserializer
https://stackoverflow.com/questions/55034165
复制相似问题