Kafka0.8全部好
Kafka0.8作品伟大。我能够使用CLI以及编写我自己的生产者/消费者！
正在检查动物园管理员。。。我还看到了为0.8成功创建的所有主题和分区。
Kafka0.7不起作用！
为什么是Kafka0.7？我使用Kafka喷口从Storm这是为Kafka0.7。
首先，我只想为Kafka 0.7运行基于CLI的producer/consumer，我无法做到这一点。我将执行以下步骤：
>
宾/Kafka控制台制作人。sh——动物园管理员本地主机：2181——主题主题时间
是时候发些信息了
[2013-06-28 14:07:19,650]INFO从0:0断开连接（kafka.producer.SyncProducer）[2013-06-28 14:07:19,653]错误连接尝试到0:0失败，下一次尝试在1 ms（kafka.producer.SyncProducer）java.net.连接异常：sun.nio.ch.Net.connect0（本地方法）sun.nio.ch.Net.connect（et.java:364）sun.nio.ch.Net.connect（et.java:356）sun.nio.ch.SocketChannelImpl.connect（SocketChannelImpl.java:623）kafka.producer.SyncProducer.connect（SyncProducer.scala:173）kafka.producer.SyncProducer.getOrMakeConnection（SyncProducer.scala:196）在kafka. producer。在kafka. producer发送（SyncProducer. scala： 92）。在kafka. producer. async.的SyncProducer. Multi发送（SyncProducer. scala： 135）。发送（DefaultEventHandler. scala： 58）在kafka. producer. async。在kafka. producer. async中的DefaultEventHandler. Handler（DefaultEventHandler. scala： 44）。producerSendThread. tryToHandle（producerSendThread. scala： 116）在scala. Collage. immutable.Stream. Foreach（Stream. scala： 254）在kafka. producer. async。在kafka. producer. async的producerSendThread. ProcEvents（producerSendThread. scala： 70）。运行（producerSendThread. scala： 41）
请注意，Zookeeper已在运行。
任何帮助都将不胜感激。
编辑：
我甚至没有看到在zookeeper中创建的主题。我正在运行以下命令：
bin/kafka-console-producer.sh --zookeeper localhost:2181 --topic topicime
命令之后一切都好
[2013-06-28 14:30:17,614] INFO Session establishment complete on server localhost/127.0.0.1:2181, sessionid = 0x13f805c6673004b, negotiated timeout = 6000 (org.apache.zookeeper.ClientCnxn)
[2013-06-28 14:30:17,615] INFO zookeeper state changed (SyncConnected) (org.I0Itec.zkclient.ZkClient)
[2013-06-28 14:30:17,700] INFO Creating async producer for broker id = 0 at 0:0 (kafka.producer.ProducerPool)
但是现在，当我键入要发送的字符串时，会出现上述错误（连接被拒绝！）
共有2个答案
考虑看看StormKafka叉子，可在https://github.com/wurstmeister/storm-kafka-0.8-plus
我正在为我们的服务器安装它=）。
INFO Disconnecting from 0:0 (kafka.producer.SyncProducer)
上面一行隐藏了错误。0:0不是有效的主机和端口。解决方案是通过在server.properties.中设置“主机名”属性，显式设置要在动物园管理员中注册的主机ip
-
问题内容： 如何从 通用JSON 获取 所有“ id”成员值 。 不知道它的结构 。因为它非常复杂并且它有很多子对象。它必须遍历所有子对象。 对于那些不断询问示例JSON在哪里的人来说。 我的问题是关于如何从具有该成员内部的任何通用JSON中提取成员值“ id”的成员值。 问题答案： 如果您不知道从某处接收到的JSON的结构，请务必注意JSON是“简单”的复合模式，您可以像其他任何复合结构一样遍历
-
问题内容： 如何使小部件全屏显示？我已经尝试过这样的事情： 但是小部件并未覆盖系统面板。还有其他想法吗？ 操作系统：Linux 问题答案： 就是您所需要的-在我的项目中的Linux + Windows上可以很好地工作多年- 但请注意，不应两次调用该函数（例如，先调用of ，然后调用）。 乔，克里斯
-
全部来源 关键参数 报告 method metrics(指标, 数据单位) 其他参数 全部来源 source/all/a pv_count (浏览量(PV)) pv_ratio (浏览量占比，%) visit_count (访问次数) visitor_count (访客数(UV)) new_visitor_count (新访客数) new_visitor_ratio (新访客比率，%) ip_co
-
问题内容： 我在一起有两个查询，所以我已经知道两个查询之间不会有重复的元素。因此，并会产生相同的结果。 我应该使用哪一个？ 问题答案： 您应该使用与您要查找的内容相匹配的语言。如果要确保没有重复使用，请使用。仅仅因为您的数据 现在 会产生相同的结果，并不意味着它总是会如此。 也就是说，在任何理智的数据库实现中都将更快，请参见下面的文章以获取示例。但通常情况下，它们是相同的，只是执行额外的步骤以删除
-
问题内容： 我正在尝试解析一个网站，并通过BeautifulSoup.findAll获取一些信息，但它并没有全部找到。.我正在使用python3 代码是这个 它只打印一半… 问题答案： 不同的HTML解析器对损坏的HTML的处理方式不同。该页面提供了损坏的HTML，解析器对此的处理不佳： 标准库在此特定页面上的麻烦较少： 使用将其转换为您的特定代码示例，您将这样指定解析器：
-
问题内容： 我使用FULL OUTER JOIN联接了2个表，这花了6分钟来运行并给出输出。 我使用LEFT OUTER JOIN和RIGHT OUTER JOIN的UNION做了同样的事情。仅用了15秒 有人知道为什么会这样吗？ 问题答案： 您可能在两个表中都有很多行，共有几行，并且所讨论的列上没有索引。