apache kafka 生产者 NetworkClient 代理服务器断开连接

Question

我是 apache kafka 的新手，我对与 apache 的连接有疑问 kafka.When 我运行配置基于 java 的 apache kafka 生产者它的工作但是当我添加打包jar 文件和运行在 apache metron kafka 代理上，出现错误，如下所示

2017-03-17 07:32:32 WARN  NetworkClient:568 - Bootstrap broker node1:6667 disconnected

配置

bootstrap.servers=node1:6667
acks=all
retries=0
batch.size=16384
linger.ms=1
buffer.memory=33554432
key.serializer=org.apache.kafka.common.serialization.StringSerializer
value.serializer=org.apache.kafka.common.serialization.StringSerializer

代码：

sender.send(new ProducerRecord<S, String>(getSenderTopic(), (S) getSenderKey(),
          data), new Callback() {
            public void onCompletion(RecordMetadata metadata, Exception e) {
              if (e != null) {
                LOGGER.error("exception ", e);
                sender.close();
              }
            }
          });

apache metron 和配置主机上的 Apache kafka 代理运行已设置 node1:6667

我认为它是网络方面的问题，但您对此有何建议？。谢谢

Answer 1

所以经过研究，我已经解决了问题，kafka 版本 apache metron 使用 10.0.1 的问题，我们使用 10.1.0，更改了 pom xml 问题解决了。

apache kafka 生产者 NetworkClient 代理服务器断开连接

apache kafka producer NetworkClient broker server disconnected

apache-kafka

kafka-producer-api