Кто-нибудь использовал CNCF CloudEvent от Apache Kafka?

Question

Я опубликовал несколько CNCF CloudEvents на Kafka Broker. Я пытаюсь просмотреть их непосредственно в брокере с помощью этой команды:

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-start

- свойство key.deserializer = org.apache.kafka.common.serialization.StringDeserializer

- значение свойства.deserializer = org.apache.kafka.common.serialization.LongDeserializer