kafka Consumer kafka_2.9.1-0.8.2.2 java消费kafka 报错求解

发布于 2021-11-29 00:09:26 字数 3126 浏览 710 评论 1

[2015-12-04 06:00:04,713] INFO 0 successfully elected as leader (kafka.server.ZookeeperLeaderElector)
[2015-12-04 06:00:05,107] INFO Got user-level KeeperException when processing sessionid:0x1516ca59dcd0000 type:delete cxid:0x4b zxid:0x4d3 txntype:-1 reqpath:n/a Error Path:/admin/preferred_replica_election Error:KeeperErrorCode = NoNode for /admin/preferred_replica_election (org.apache.zookeeper.server.PrepRequestProcessor)
[2015-12-04 06:00:05,124] INFO New leader is 0 (kafka.server.ZookeeperLeaderElector$LeaderChangeListener)
[2015-12-04 06:00:05,136] INFO Registered broker 0 at path /brokers/ids/0 with address 192.16.16.10:9092. (kafka.utils.ZkUtils$)
[2015-12-04 06:00:05,162] INFO [Kafka Server 0], started (kafka.server.KafkaServer)
[2015-12-04 06:00:05,526] INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions [TEST-TOPIC,0],[topic1,0],[topic2,0],[page_visits,0],[ips,0],[mykafka,0],[topic3,0],[test,0] (kafka.server.ReplicaFetcherManager)
[2015-12-04 06:00:05,696] INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions [TEST-TOPIC,0],[topic1,0],[topic2,0],[page_visits,0],[ips,0],[mykafka,0],[topic3,0],[test,0] (kafka.server.ReplicaFetcherManager)
[2015-12-04 06:00:21,223] INFO Accepted socket connection from /192.16.16.1:56239 (org.apache.zookeeper.server.NIOServerCnxnFactory)
[2015-12-04 06:00:21,228] INFO Client attempting to establish new session at /192.16.16.1:56239 (org.apache.zookeeper.server.ZooKeeperServer)
[2015-12-04 06:00:21,230] INFO Established session 0x1516ca59dcd0001 with negotiated timeout 6000 for client /192.16.16.1:56239 (org.apache.zookeeper.server.ZooKeeperServer)
[2015-12-04 06:00:21,348] INFO Got user-level KeeperException when processing sessionid:0x1516ca59dcd0001 type:create cxid:0x1 zxid:0x4de txntype:-1 reqpath:n/a Error Path:/consumers Error:KeeperErrorCode = NodeExists for /consumers (org.apache.zookeeper.server.PrepRequestProcessor)
[2015-12-04 06:00:21,348] INFO Got user-level KeeperException when processing sessionid:0x1516ca59dcd0001 type:create cxid:0x2 zxid:0x4df txntype:-1 reqpath:n/a Error Path:/consumers/group1 Error:KeeperErrorCode = NodeExists for /consumers/group1 (org.apache.zookeeper.server.PrepRequestProcessor)
[2015-12-04 06:00:21,348] INFO Got user-level KeeperException when processing sessionid:0x1516ca59dcd0001 type:create cxid:0x3 zxid:0x4e0 txntype:-1 reqpath:n/a Error Path:/consumers/group1/ids Error:KeeperErrorCode = NodeExists for /consumers/group1/ids (org.apache.zookeeper.server.PrepRequestProcessor)
[2015-12-04 06:00:21,755] INFO Closing socket connection to /192.16.16.1. (kafka.network.Processor)
[2015-12-04 06:00:22,090] INFO Closing socket connection to /192.16.16.1. (kafka.network.Processor)
[2015-12-04 06:00:22,377] INFO Closing socket connection to /192.16.16.1. (kafka.network.Processor)
[2015-12-04 06:00:22,591] INFO Closing socket connection to /192.16.16.1. (kafka.network.Processor)
[2015-12-04 06:00:22,805] INFO Closing socket connection to /192.16.16.1. (kafka.network.Processor)

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(1

月牙弯弯 2021-11-30 07:33:51

我也是这样,什么原因呢?楼主解决了没有?

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文