apache-kafka - 有人用过 Apache Kafka 的 CNCF CloudEvent 吗？

Question

我已经在 Kafka Broker 上发布了几个 CNCF CloudEvents。我正在尝试使用以下命令直接在代理上查看它们：

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic flink-test --from-beginning

我无法查看任何数据。对于使用的任何其他序列化格式，我从来没有遇到过这个问题。有人有什么想法吗？

Answer 1

我认为，您应该在将消息发送到代理时使用的命令中包含 key.deserializer 和 value.deserializer。

例子-

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic flink-test --from-beginning

--property key.deserializer=org.apache.kafka.common.serialization.StringDeserializer

--property value.deserializer=org.apache.kafka.common.serialization.LongDeserializer