Возникла исключительная ситуация. Код ошибки не найден - Confluent - PullRequest
Новая
       48

Возникла исключительная ситуация. Код ошибки не найден - Confluent

0 голосов
/ 05 сентября 2018

Я вижу ошибку в моих журналах, что Subject с именем A.Abc-key отсутствует. Я перечислил все предметы и подтвердил, что A.Abc-ключ отсутствует, но A.Abc-значение присутствует

При проверке ключа свойства для той же темы я получаю следующую ошибку:

. / Kafka-avro-console-customer --bootstrap-server http://localhost:9092 --из начала --property print.key = true --topic A.Abc 

null    Processed a total of 1 messages
[2018-09-05 16:26:45,470] ERROR Unknown error when running consumer:  (kafka.tools.ConsoleConsumer$:76)
org.apache.kafka.common.errors.SerializationException: Error deserializing Avro message for id 80
Caused by: java.net.ConnectException: Connection refused (Connection refused)
    at java.net.PlainSocketImpl.socketConnect(Native Method)

Я не уверен, что можно отлаживать и исправлять ошибки.

1 Ответ

0 голосов
/ 06 сентября 2018

Ваша ошибка связана с HTTP, поэтому убедитесь, что ваш реестр работает на локальном хосте, поскольку вы его не указали

и проверил, что ключ A.Abc отсутствует

Тогда ваш ключ не Avro, но потребитель консоли Avro попытается десериализовать ваши ключи как Avro, если вы добавите свойство ключа печати

Вы можете попробовать добавить key-deserializer, и если ваш реестр не на localhost, вы должны указать его 

--property schema.registry.url="http://..." \
--property key-deserializer=org.apache.kafka.common.serialization.StringDeserializer \
--property print.key=true
...