从 Kafka docker 镜像中使用奇怪的数据

Question

我正在使用汇合的kafka docker

confluentinc/cp-server:5.4.0

我正在从 postgresql 生成数据。

当我创建一个消费者并想要检索kafka消息时，它会以这样的格式出现

codesc�����[�c81e728d9d0.9.4.Finalpostgresqlconektatestdb��ך���KЗ��� public 

                                        

有什么方法可以将其检索为 Json 吗？

Answer 1

不清楚您在连接器中使用了什么

value.converter

。

如果你使用 Avro，你会运行

kafka-avro-console-consumer

如果你使用任何其他的，你会运行

kafka-console-consumer

Answer 2

对我来说看起来像 Avro。您可以使用

kafka-avro-console-consumer

阅读它

kafka-avro-console-consumer \
--bootstrap-server broker:9092 \
--property schema.registry.url=http://schema-registry:8081 \
--topic conekta.public.codes \
--from-beginning 

确保将

schema-registry

设置为架构注册表的主机名。

参考：

• 序列化方法