topic-iamtopic在60000毫秒后元数据中不存在

e0bqpujr  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(810)

我们有Kafka制作人建筑申请。我需要为同样的问题编写集成测试用例。我尝试使用dockerimagename和嵌入的kafka类创建zookeeper和kafka intance。如果我在我的zookeper和kafka被创建的同一个类中创建producer,它运行良好。但当我试图从另一个类触发producer时,它给出了以下错误:

> 2020-08-21 22:53:27 org.apache.kafka.clients.NetworkClient:755 [WARN]
> [Producer clientId=producer-1] Connection to node -1
> (localhost/127.0.0.1:32772) terminated during authentication. This may
> happen due to any of the following reasons: (1) Authentication failed
> due to invalid credentials with brokers older than 1.0.0, (2) Firewall
> blocking Kafka TLS traffic (eg it may only allow HTTPS traffic), (3)
> Transient network issue. 2020-08-21 22:53:27
> org.apache.kafka.clients.NetworkClient:1030 [WARN] [Producer
> clientId=producer-1] Bootstrap broker localhost:32772 (id: -1 rack:
> null) disconnected 2020-08-21 22:53:28
> org.apache.kafka.clients.NetworkClient:755 [WARN] [Producer
> clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:32772)
> terminated during authentication. This may happen due to any of the
> following reasons: (1) Authentication failed due to invalid
> credentials with brokers older than 1.0.0, (2) Firewall blocking Kafka
> TLS traffic (eg it may only allow HTTPS traffic), (3) Transient
> network issue. 2020-08-21 22:53:28
> org.apache.kafka.clients.NetworkClient:1030 [WARN] [Producer
> clientId=producer-1] Bootstrap broker localhost:32772 (id: -1 rack:
> null) disconnected java.util.concurrent.ExecutionException:
> org.apache.kafka.common.errors.TimeoutException: Topic Iamtopic not
> present in metadata after 60000 ms.

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题