目标：我正试图用java语言向Kafka发送消息。
这是一种痛苦。。
让我简单描述一下。
我已经在centos虚拟机上安装了kafka。
我用它附带的zookeeper、服务器、生产者和客户机运行了所有默认属性文件。
我成功地发送和接收消息。
我有一个telnet连接，从我的电脑到zookeeper（2181）端口和kafka服务器（9092）端口的虚拟机。
现在，我想编写java代码来向主题发送消息。我使用网站上的“快速入门”中的示例：

Properties props = new Properties();
props.put("zk.connect", "http://XX.XX.XX.XX:2181"); //  where X is the ip
props.put("serializer.class", "kafka.serializer.StringEncoder");
producer = new Producer<String, String>(new ProducerConfig(props));

它在第四行失败，但有以下例外：

kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries

以及

rg.I0Itec.zkclient.exception.ZkTimeoutException: Unable to connect to zookeeper server within timeout: 400

问题。
例外。
错误参数：
在kafka快速入门示例中，我看到它只需要zk.connect、serializer.class。当我运行它时，它会在producer的构造函数中大叫它需要metadata.broker.list。
是吗？所以我感觉Kafka服务器的ip和端口。
顺便说一句-是zk.connect还是zookeeper connect？zktimeoutexception:无法在超时时间内连接到zookeeper服务器：400
maven坏版本
我去了网站，我看到最新的版本是Kafka2.8.0-0.8.0。
问题1-我使用intelij下载它（我认为它是maven central）-
我得到了所有相关的jar——只是kafka jar是空的（只包含清单）。
问题2-有比网站上的版本更高的版本。他们是官方的吗。
无论如何，我下载了org.apache。kafka:kafka_2.10:0.8.0
使用wireshark，我看到三个syn&ack（三重握手），然后是fyn&ack
刚好在…之后。在zookeeper的日志中，我看到以下[2014-02-27 01:43:42127]warn endofstreamexception:无法从客户端sessionid 0x0读取其他数据，可能客户端已关闭套接字
（org.apache.zookeeper.server.nioservercnxn）
这意味着我关闭了连接。为什么？