apache-kafka - 使用来自 Kafka docker 镜像的奇怪数据

Question

我正在使用融合的 kafka docker

confluentinc/cp-server:5.4.0

我正在从 postgresql 生成数据。

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

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

                                        

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

标签： apache-kafkaapache-kafka-connect

Answer 1

不清楚value.converter您在连接器中使用了什么。

如果你使用 Avro，你会运行kafka-avro-console-consumer

如果你使用任何其他的，你会运行kafka-console-consumer