Я пытался подключиться с kafka-avro-console-consumer от Confluent к нашему устаревшему кластеру Kafka, который был развернут без реестра Confluent Schema.Я предоставил схему явно, используя такие свойства, как:
kafka-console-consumer --bootstrap-server kafka02.internal:9092 \
--topic test \
--from-beginning \
--property key.schema='{"type":"long"}' \
--property value.schema='{"type":"long"}'
, но я получаю «Неизвестный магический байт!»ошибка с org.apache.kafka.common.errors.SerializationException
Возможно ли использовать сообщения Avro от Kafka с помощью Confluent kafka-avro-console-consumer, которые не были сериализованы с AvroSerializer из Confluent и с реестром схем?