java - 从主机操作系统访问沙箱中的 kafka(尝试所有解决方案后)

Question

认为我是个菜鸟。我已经阅读了有关堆栈溢出的所有问题并尝试了一天，但解决方案就是不点击我。请专门帮助我设置和代码(因为我已经尝试了堆栈溢出时相同问题的所有可能性 - )

这是我的 Producer.properties 文件

这是我的 server.properties 文件

这是我的代码

Properties props = new Properties();
props.put("metadata.broker.list", "sandbox.hortonworks.com:9093");
//props.put("zk.connect", "sandbox.hortonworks.com:2181");
props.put("serializer.class", "kafka.serializer.StringEncoder");
props.put("request.required.acks", "1");

KeyedMessage<String, String> data = new KeyedMessage<String, String> (topic1,"ccccccccc");


System.out.println(data);
producer.send(data);

这是 eclipse 输出

KeyedMessage(tweeter,null,ccccccccc)
kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.

Answer 1

@Samhash，根据我的理解，advertised.host.name 应该是一个 IP 地址，可以从您的本地计算机 ping 通。对于您的本地计算机，我认为 sandbox.hortonworks.com 不会被理解，否则您可能必须在本地计算机中为此主机创建一个条目。
请告诉我它是否适合您。