发生异常主题未找到错误代码-合流

nszi6y05 于 2021-06-06 发布在 Kafka

关注(0)|答案(1)|浏览(244)

我可以在日志中看到名为a.-key的主题不存在的错误。我列出了所有的主题，并验证了a.键不存在，但a.值存在
检查同一主题的属性键时，出现以下错误：
./kafka avro console consumer—引导服务器http://localhost：9092--从头--属性print.key=true--主题a.

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)

我不确定如何调试和修复这个问题。

avro apache-kafka confluent-platform confluent-schema-registry

来源：https://stackoverflow.com/questions/52183606/exception-occurred-subject-not-found-error-code-confluent

1条答案

按热度按时间

rjjhvcjd1#

您的错误与http有关，因此请确保您的注册表正在localhost上运行，因为您没有指定它
并确认a.键不存在
然后您的密钥不是avro，但是如果您添加print key属性，avro控制台使用者将尝试将您的密钥反序列化为avro
你可以尝试添加 key-deserializer 如果您的注册表不在localhost上，则必须指定它

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

赞(0）回复(0）举报 2021-06-07

我来回答

发生异常主题未找到错误代码-合流

1条答案

相关问题

热门标签

最新问答