我试着用合流的 kafka-avro-console-consumer ,但如何将模式注册表的参数传递给它?
kafka-avro-console-consumer
fiei3ece1#
猜猜你在找什么。。。
kafka-avro-console-consumer --topic topicX --bootstrap-server kafka:9092 \ --property schema.registry.url="http://schema-registry:8081"
不,不能指定架构版本。id直接从主题中的avro数据中使用。主题名称Map到主题名称。使用 --property print.key=true 查看Kafka信息键。这是常规控制台使用者的一般属性。这些是avro console consumer脚本中唯一的额外选项,这意味着除了在 kafka-consumer-consumer ,您只能提供 --formatter 或者 --property schema.registry.url ,并且没有其他特定于模式注册表的参数(无论这些参数是什么)
--property print.key=true
kafka-consumer-consumer
--formatter
--property schema.registry.url
for OPTION in "$@" do case $OPTION in --formatter) DEFAULT_AVRO_FORMATTER="" ;; --*) ;; *) PROPERTY=$OPTION case $PROPERTY in schema.registry.url*) DEFAULT_SCHEMA_REGISTRY_URL="" ;; esac ;; esac done
1条答案
按热度按时间fiei3ece1#
猜猜你在找什么。。。
不,不能指定架构版本。id直接从主题中的avro数据中使用。主题名称Map到主题名称。
使用
--property print.key=true
查看Kafka信息键。这是常规控制台使用者的一般属性。这些是avro console consumer脚本中唯一的额外选项,这意味着除了在
kafka-consumer-consumer
,您只能提供--formatter
或者--property schema.registry.url
,并且没有其他特定于模式注册表的参数(无论这些参数是什么)