无法在windows中使用kafka cmd创建使用者
我还更改了zookeeper中的zoo.cfg。
dataDir=D:/WEBSOCKET/zookeeper-3.4.12/data
和server.properties。
log.dirs=D:/WEBSOCKET/kafka_2.12-2.1.0/logs
我看了所有的教程，并做了完全相同的方法。还有乌斯金Kafka开放式动物园管理员。
3）创建主题
.\bin\windows\kafka-topics.bat--create-zookeeper localhost:2181-replication-factor 1-partitions 1-topic hello
4）创建生产者
.\bin\windows\kafka-console-producer.bat--bootstrap-server localhost：2181-主题hello
5）创建消费者
.\bin\windows\kafka-console-consumer.bat--bootstrap-server localhost：2181-主题hello
WARN [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxn@383] - Exception causing close of session 0x0: null
INFO [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxnFactory@215] - Accepted socket connection from /127.0.0.1:55192
2019-01-08 17:05:24,822 [myid:] - INFO [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxn@1040] - Closed socket connection for client /127.0.0.1:50874 (no session established for client)
2019-01-08 17:05:25,783 [myid:] - INFO [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxnFactory@215] - Accepted socket connection from /127.0.0.1:56089
我不知道怎么修好它。我谷歌了两天...
当我用步骤2打开我的Kafka时，我的动物园管理员有时没有任何反应，或者给我看这个：
[ProcessThread(sid:0 cport:2181)::PrepRequestProcessor@596] - Got user-level KeeperException when processing sessionid:0x1000058f8960000 type:multi cxid:0x36 zxid:0x69 txntype:-1 reqpath:n/a aborting remaining multi ops. Error Path:/admin/preferred_replica_election Error:KeeperErrorCode = NoNode for /admin/preferred_replica_election
我也谷歌这个，但没有帮助。
共有1个答案
生产者和消费者需要使用端口9092（Kafaka）
您正在看到Zookeeper日志和错误，因为您正在尝试使用bootstrap-server或broker-list和端口2181（Zookeeper）
再次查看快速入门指南
-
我需要一个用于私有方法测试的powermock 如果我只使用@RunWith（PowerMockRunner.class）而不使用@powermockrunnerregate（SpringJUnit4ClassRunner.class），效果会很好 我需要使用@powermockrunnerregate（SpringJUnit4ClassRunner.class）来表示@autowired。但它并
-
问题内容： 我无法在数据库（mySQL）中创建表，使用并尝试使用以下命令输入未来表的名称： 然后，在用户输入表名称之后，我尝试构造并调用该语句： 如果我尝试不输入名称就执行它（如常量字符串：“ CREATE TABLE newtable（…）”，但我需要输入名称），它将很好地工作。 问题答案： 阅读表名后，您将必须格式化字符串，例如： 然后创建像：
-
我在Microsoft Windows7上使用的是。我想在一个变量中加载csv文件，以便稍后执行与SQL相关的操作，但无法这样做。我从这个链接引用了公认的答案，但没有用。我按照以下步骤创建对象和对象： 当我尝试时，它会说没有找到df。我尝试了从附加链接加载CSV的databricks解决方案。它下载软件包，但不加载csv文件。那么我怎样才能纠正我的问题呢？提前致谢：）
-
我无法在Spark数据库中创建H2OContext--使用PySparkling。它给出了以下错误。 代码：从pysparkling导入* 代码：导入H2O 代码:H2OConf=H2OConf(Sark) 代码:H2OConf.set（“spark.ui.enabled”，True） 代码:h2oContext=h2oContext.getorcreate（spark,h2oConf) 错误：j
-
我正在使用java创建一个zip文件，但我无法得到任何代码工作。我尝试了很多特定于Java7和Java8的方法，但所有的方法都显示出某种错误，是我的代码中有错误还是需要改进？ 在这一行出现错误 请指导我：） 运行时出错：
-
我正试图使用Maven在Eclipse中创建一个Vaadin应用程序，但无法这样做。官方说明(https://vaadin.com/wiki/-/wiki/main/creating%20an%20Eclipse%20project)说要在Eclipse中创建一个新的Maven项目，在原型列表中创建“”vaadin-archetype-application“，我看不到这种类型的东西，然后，我添加