Использование странных данных из изображения Кафки docker

Question

Привет, ребята, я использую конфлюентную кафку docker

confluentinc/cp-server:5.4.0

Я создаю данные из postgresql, когда я создаю потребителя и хочу удалить сообщение Кафки, которое появляется в формат, подобный этому

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

, есть ли способ получить его как Json?

Answer 1

Похоже, Авро для меня. Вы можете прочитать его, используя 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

Answer 2

Не ясно, что value.converter вы использовали в Соединителе.

Если бы вы использовали Avro, вы бы запустили kafka-avro-console-consumer

Если бы вы использовали любой другой, вы бы запустили kafka-console-consumer