我正在尝试使用java中的kafkaapi。我使用以下maven依赖项：

<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-clients</artifactId>
    <version>0.8.2.0</version>
</dependency>

我无法连接到远程Kafka服务器。我将kafka'server.properties'文件端口属性更改为端口8080。我可以启动zookeeper和kafka服务器没问题。我还可以使用kafka下载附带的控制台生产者和消费者应用程序(scala 2.10版）
我使用以下客户机代码创建一个远程kafkaproducer

Properties propsProducer = new Properties();

propsProducer.put("bootstrap.servers", "172.xx.xx.xxx:8080");
propsProducer.put("key.serializer", org.apache.kafka.common.serialization.ByteArraySerializer.class);
propsProducer.put("value.serializer", org.apache.kafka.common.serialization.ByteArraySerializer.class);
propsProducer.put("topic.metadata.refresh.interval.ms", "0");

KafkaProducer<byte[], byte[]> m_kafkaProducer = new KafkaProducer<byte[], byte[]>(propsProducer);

一旦我创建了producer，我就可以运行下面的行并返回有效的主题信息，只要strtopic是一个现有的主题名。

List<PartitionInfo> partitionInfo = m_kafkaProducer.partitionsFor(strTopic);

当我尝试发送消息时，我会执行以下操作：

ProducerRecord<byte[], byte[]> prMessage = new ProducerRecord<byte[],byte[]>(strTopic, strMessage.getBytes());

RecordMetadata futureData = m_kafkaProducer.send(prMessage).get();

对send（）的调用会无限期地阻塞，当我手动终止该进程时，我会看到关闭套接字的错误是因为kafka服务器上的错误（ioexception，connection reset by peer）错误。
另外，host.name、advised.host.name和advised.port属性仍然在“server.properties”文件中被注解掉，这一点也不值一提。哦，如果我换线的话：

propsProducer.put("bootstrap.servers", "172.xx.xx.xxx:8080");

到

propsProducer.put("bootstrap.servers", "127.0.0.1:8080");

在安装kafka服务器的同一台服务器上运行，它可以工作，但我正在尝试远程使用它。
感谢任何帮助，如果我能澄清，让我知道。