从外面连接kafka的问题

我正在使用hortonwork Sandbox for kafka服务器尝试使用java代码连接eclipse中的kafka.使用此配置连接到生产者以发送消息

metadata.broker.list=sandbox.hortonworks.com:45000
serializer.class=kafka.serializer.DefaultEncoder
zk.cOnnect=sandbox.hortonworks.com:2181
request.required.acks=0
producer.type=sync

sandbox.hortonworks.com是我连接的沙箱名称

在kafka server.properties中,我更改了此配置

host.name=sandbox.hortonworks.com

advertised.host.name=System IP(on which my eclipse is running)
advertised.port=45000

也做了端口转发,

我能够从eclipse连接到kafka服务器但是在发送消息时获得异常异常"3次尝试后无法发送消息".

首先确保您已为Hortonworks Sandbox VM配置了仅主机网络,如下所述:

http://hortonworks.com/community/forums/topic/use-host-only-networking-for-the-virtual-machine/

执行此操作后,您的沙箱VM应该获得一个IP(例如192.168.56.101),它应该可以通过SSH从您的主机访问

$ ssh root@192.168.56.101

然后在http://192.168.56.101:8080/打开Ambari 并将Kafka配置更改为

listeners=PLAINTEXT://0.0.0.0:6667
advertised.listeners=PLAINTEXT://192.168.56.101:6667 

必须在"自定义kafka-broker"部分添加后一个属性(另请参阅http://hortonworks.com/community/forums/topic/ambari-alerts-how-to-change-kafka-port/).

然后通过Ambari开始/重启Kafka.您现在应该可以从Hortonworks Sandbox VM外部访问Kafka.您可以使用例如Kafka发行版中的Kafka控制台生成器来测试(从沙盒VM外部)

$ bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
$ bin/kafka-console-producer.sh --topic test --broker-list 192.168.56.101:6667