apache-kafka - Kafka Avro コンソール コンシューマーを使用するときに、特定のスキーマ レジストリのパラメーターを渡す方法は?

Question

Confluent を使用しようとしてkafka-avro-console-consumerいますが、Schema Registry のパラメータをそれに渡すにはどうすればよいですか?

Answer 1

あなたが探しているものを推測してください...

kafka-avro-console-consumer --topic topicX --bootstrap-server kafka:9092 \ 
    --property schema.registry.url="http://schema-registry:8081"

いいえ、スキーマのバージョンを指定することはできません。ID は、トピック内の Avro データから直接使用されます。サブジェクト名はトピック名にマップされます。

--property print.key=trueKafka メッセージ キーを表示するために使用します。これは、通常のコンソール コンシューマーの一般的なプロパティです。

これらは 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