是否有人从Apache Kafka那里消费了CNCF CloudEvent

Question

我已将几个CNCF Cloudevents发布到了Kafka经纪人上。我正在尝试使用此命令在经纪上直接查看它们：

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

我无法查看任何数据。我从来没有使用过任何其他序列化格式来解决这个问题。有人想到了吗？

Answer 1

我认为，您应该在您的命令中包含key.deSerializer和value.dealialializer。

示例 -

kafka-console-consumer.sh- bootstrap-server localhost：9092 - 题为弗林克测试 - 从

- 属性key.deserializer = org.apache.kafka.common.serialization.stringDeserializer

- 属性value.deserializer = org.apache.kafka.common.serialization.longdeserializer