kafka Consumer kafka_2.9.1-0.8.2.2 java消费kafka 报错求解
[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 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论
评论(1)
我也是这样,什么原因呢?楼主解决了没有?