Kafka 消费者 CLI 中未显示数值

Question

通过 运行 Confluent 5.1.0.

将 Avro 文件中的数据写入主题

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

kafka_2.12-2.1.0 root$ 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}

实际：

SQE iSealDEVVeracodeN?V

SQE iSealDEVCheckmarxY?V

Answer 1

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

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