发生异常主题未找到错误代码 - 汇合答案

【问题标题】：Exception Occurred Subject not found error code - Confluent发生异常主题未找到错误代码 - 汇合
【发布时间】：2019-02-10 12:13:18
【问题描述】：

我可以在日志中看到名为 A.Abc-key 的主题不存在的错误。我列出了所有主题并验证了 A.Abc-key 不存在但 A.Abc-value 存在

在检查同一主题的属性键时，我收到以下错误：

./kafka-avro-console-consumer --bootstrap-server http://localhost:9092 --from-beginning --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)

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

【问题讨论】：

标签： apache-kafka avro confluent-platform confluent-schema-registry

【解决方案1】：

您的错误与 HTTP 有关，因此请确保您的注册表在 localhost 上运行，因为您没有指定它

并验证 A.Abc-key 不存在

那么您的密钥不是 Avro，但如果您添加打印密钥属性，Avro 控制台消费者将尝试将您的密钥反序列化为 Avro

您可以尝试添加key-deserializer，如果您的注册表不在本地主机上，则必须指定它

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

【讨论】：