我正在使用汇合的kafka docker
confluentinc/cp-server:5.4.0
我正在从 postgresql 生成数据。
当我创建一个消费者并想要检索kafka消息时,它会以这样的格式出现
codesc�����[�c81e728d9d0.9.4.Finalpostgresqlconektatestdb��ך���KЗ��� public
有什么方法可以将其检索为 Json 吗?
不清楚您在连接器中使用了什么
value.converter
。
如果你使用 Avro,你会运行
kafka-avro-console-consumer
如果你使用任何其他的,你会运行
kafka-console-consumer
对我来说看起来像 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
设置为架构注册表的主机名。
参考: