找不到主题融合 kafka 架构注册表error_code“：40401，”消息

Question

我使用的是Kafka confluent schema registry docker镜像，当我在本地测试它时（使用本地安装的Kafka，这可以按预期工作，但当我尝试将其用于远程Kafka集群时，我遇到了一个错误：

< code>{"error_code":40401，" message ":"未找到主题。io . confluent . rest . exceptions . restnotfoundexception:找不到主题。\ nio . confluent . rest . exceptions . restnotfoundexception:找不到主题。\ n \ tat io . confluent . Kafka . schema registry . rest . exceptions . errors . subjectnotfoundexception(errors . Java:51)\ n \ tat io . confluent . Kafka . schema registry . rest . resources . subjectversions resource . list versions(subjectversions resource . Java:157)\ n \ tat sun . reflect . nativemethodaccessorimpl . invoke 0(Native方法)\ tat sun . reflect . nativemethodaccessorimpl . invoke(nativemethodaccessorimpl . Java:67

下面是我用它来运行docker的命令

docker run  --network host -p 8081:8081        -e  SCHEMA_REGISTRY_KAFKASTORE_BOOTSTRAP_SERVERS=first_broker:9092,second_broker:9092,third_broker:9092    -e SCHEMA_REGISTRY_HOST_NAME=0.0.0.0     -e SCHEMA_REGISTRY_LISTENERS=http://0.0.0.0:8081     -e SCHEMA_REGISTRY_DEBUG=true confluentinc/cp-schema-registry:latest

我得到的错误堆栈是:

    Producer clientId=producer-1] Updated cluster metadata updateVersion 2 to MetadataCache{cluster=Cluster(id = dIU-fffyfHXRDeVgZA4fud_eBw, nodes = [first_broker:9092 (id: 2 rack: subnret-0ecf514e9ghg94d5197a7), second_broker:9092 (id: 1 rack: subrnet-0befbedzd392e5497137), third_broker:9092 (id: 3 rack: subnret-0rrc00cc1dbd14c0350)], partitions = [Partition(topic = topics, partition = 0, leader = 1, replicas = [1,3,2], isr = [1,3,2], offlineReplicas = [])], controller = first_broker:9092 (id: 3 rack: subnret-0c0rr0cc1dbd14c0350))}
Sending POST with input {"schema":"\"string\""} to http://0.0.0.0:8081/subjects/topicName-value/versions
org.apache.kafka.common.errors.SerializationException: Error serializing Avro message
Caused by: java.net.SocketException: Unexpected end of file from server
    at sun.net.www.http.HttpClient.parseHTTPHeader(HttpClient.java:851)
    at sun.net.www.http.HttpClient.parseHTTP(HttpClient.java:678)
    at sun.net.www.http.HttpClient.parseHTTPHeader(HttpClient.java:8

我注意到在远程Kafka集群中，我创建了_schemas主题，但是当我使用消费者控制台从这个主题_shemas读取数据时，我得到了以下结果：

{"keytype":"NOOP","magic":0}-null
{"keytype":"NOOP","magic":0}-null
{"keytype":"NOOP","magic":0}-null
{"keytype":"NOOP","magic":0}-null
{"keytype":"NOOP","magic":0}-null
{"keytype":"NOOP","magic":0}-null
{"keytype":"NOOP","magic":0}-null
{"keytype":"NOOP","magic":0}-null
{"keytype":"NOOP","magic":0}-null
{"keytype":"NOOP","magic":0}-null
{"keytype":"NOOP","magic":0}-null
{"keytype":"NOOP","magic":0}-null
{"keytype":"NOOP","magic":0}-null

知道如何解决这个问题吗？

Answer 1

SCHEMA_REGISTRY_HOST_NAME应该是可解析的主机名，而不是0.0.0.0

同样，不要在您的生成器代码中使用< code > http://0 . 0 . 0:8081 。

侦听器是绑定地址，但也可以省略它们，只要您转发了端口，并且您删除了 --network host

您可以忽略注册表中的NOOP消息（它会在启动时吐出其中两条消息，以找到主题的结尾）