当使用kafka avro console consumer时,如何传递特定模式注册表的参数?

b5buobof  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(828)

我试着用合流的 kafka-avro-console-consumer ,但如何将模式注册表的参数传递给它?

fiei3ece

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 ,并且没有其他特定于模式注册表的参数(无论这些参数是什么)

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

相关问题