Как передать параметры для конкретного реестра схемы при использовании Kafka Avro Console Consumer?

Просто угадайте, что вы ищете ...

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

Нет, вы не можете указать версию схемы. Идентификатор берется непосредственно из данных Avro в теме. Название темы сопоставляется с названием темы.

Используйте --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