apache-kafka - Kafka 控制台消费者在 HDP 3 中读取 avro 消息
问题描述
尝试使用来自控制台消费者的 kafka Avro 消息,但不确定如何反序列化消息。
sh /usr/hdp/current/kafka-broker/bin/kafka-console-consumer.sh --bootstrap-server localhost:6667 --topic test --consumer.config /home/user/kafka.consumer.properties --from-beginning --value-deserializer ByteArrayDeserializer
测试主题的模式注册表中的 Avro 模式是:
{
"type": "record",
"namespace": "test",
"name": "TestRecord",
"fields": [
{
"name": "Name",
"type": "string",
"default": "null"
},
{
"name": "Age",
"type": "int",
"default": -1
}
]
}
使用 HDP 3.1 版本和 Kafka-clients-2.0.0.3.1.0.0-78
有人可以帮我从控制台读取 Avro 消息所需的反序列化器是什么。
解决方案
利用kafka-avro-console-consumer
例如
sh /usr/hdp/current/kafka-broker/bin/kafka-avro-console-consumer.sh \
--bootstrap-server localhost:6667 \
--topic test \
--from-beginning \
--property schema.registry.url=http://localhost:8081
推荐阅读
- node.js - Jimp:从 24 位 bmp 获取像素的 rgb 颜色
- asp.net - 服务器上的 .net 5.0 项目每隔几个小时启动一次,为什么?
- jetty - 如何使用 RSA 加密对 ActiveMQ Web 控制台(码头)进行加密?
- ms-access - 访问表达式,加一年,减一天
- varnish - 为 Varnish 安装 VMOD basic-auth
- c++ - C ++:对模板类型列表进行映射操作
- c# - FASTER 可以(轻松)用作 ACID 数据库吗?
- sql - 使用单个查询从两个表中获取行
- deep-learning - Yolo V3:图片中混合类时性能不佳
- excel - 如何将 xls 文件导出到从文件夹中读取它们的 txt 文件(Visual Basic)?