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

Question

我正在使用 confluent 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

对我来说看起来像阿夫罗。您可以使用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设置为架构注册表的主机名。

裁判：

• 序列化方法
• Kafka Connect 中的转换器