数字值未在Kafka使用者CLI中显示

Question

通过运行Confluent 5.1.0将数据从Avro文件写入主题。

当我运行Kafka使用者命令时，数值不显示。

Ptns-MacBook-Pro:kafka_2.12-2.1.0 ptn$ bin/kafka-console-consumer.sh
--bootstrap-server 127.0.0.1:9092 --topic Initiate_scans

我可以在java日志中看到预期的输出。

预期：

{“app_id”：“SQE”，“app_name”：“iSeal”，“dev_stage”：“DEV”，“scan_name”：“Veracode”，“seq_num”：1，“result_flg”：“N”，“request_id” ：5534，“scan_number”：1}

{“app_id”：“SQE”，“app_name”：“iSeal”，“dev_stage”：“DEV”，“scan_name”：“Checkmarx”，“seq_num”：3，“result_flg”：“Y”，“request_id” ：5534，“scan_number”：2}

实际：

什么是替代品？

天堂和十万家？

Answer 1

kafka-console-consumer将显示UTF-8解码的二进制数据。

如果您在Confluent的KafkaAvroSerializer（或类似库）的制作人主题中有Avro，那么您将需要使用kafka-avro-console-consumer，它将Avro转换为JSON记录。