I use the scala 2.10 version, use the example code, but meet the follow error:
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka_2.10</artifactId>
<version>0.8.0-beta1</version>
</dependency>
Client side error
==================================
2013-09-26 14:05:23 [main-SendThread(10.13.80.124:2181)] DEBUG
org.apache.zookeeper.ClientCnxn - Reading reply sessionid:0x141584facc80005,
packet:: clientPath:null serverPath:null finished:false header:: 9,8
replyHeader:: 9,74,0 request:: '/consumers/test-consumer-group/ids,T
response:: v{'test-consumer-group_JINKUISHI-1380175522393-2924590f}
2013-09-26 14:05:23 [main-SendThread(10.13.80.124:2181)] DEBUG
org.apache.zookeeper.client.ZooKeeperSaslClient - Could not retrieve login
configuration: java.lang.SecurityException: 无法定位登录配置
2013-09-26 14:05:23 [main-SendThread(10.13.80.124:2181)] DEBUG
org.apache.zookeeper.client.ZooKeeperSaslClient - Could not retrieve login
configuration: java.lang.SecurityException: 无法定位登录配置
2013-09-26 14:05:23 [main-SendThread(10.13.80.124:2181)] DEBUG
org.apache.zookeeper.client.ZooKeeperSaslClient - Could not retrieve login
configuration: java.lang.SecurityException: 无法定位登录配置
2013-09-26 14:05:23 [main-SendThread(10.13.80.124:2181)] DEBUG
org.apache.zookeeper.client.ZooKeeperSaslClient - Could not retrieve login
configuration: java.lang.SecurityException: 无法定位登录配置
2013-09-26 14:05:23 [main-SendThread(10.13.80.124:2181)] DEBUG
org.apache.zookeeper.client.ZooKeeperSaslClient - Could not retrieve login
configuration: java.lang.SecurityException: 无法定位登录配置
2013-09-26 14:05:23 [main-SendThread(10.13.80.124:2181)] DEBUG
org.apache.zookeeper.client.ZooKeeperSaslClient - Could not retrieve login
configuration: java.lang.SecurityException: 无法定位登录配置
On the server side log:
[2013-09-26 14:21:38,352] WARN Exception causing close of session
0x141584facc80005 due to java.io.IOException: Connection reset by peer
(org.apache.zookeeper.server.NIOServerCnxn)
[2013-09-26 14:21:38,353] INFO Closed socket connection for client
/10.1.156.128:52305 which had sessionid 0x141584facc80005
(org.apache.zookeeper.server.NIOServerCnxn)
[2013-09-26 14:21:40,099] INFO Closing socket connection to /10.1.156.128.
(kafka.network.Processor)
[2013-09-26 14:21:40,113] INFO Accepted socket connection from
/10.1.156.128:53702 (org.apache.zookeeper.server.NIOServerCnxn)
[2013-09-26 14:21:40,117] INFO Client attempting to establish new session at
/10.1.156.128:53702 (org.apache.zookeeper.server.NIOServerCnxn)
[2013-09-26 14:21:40,119] INFO Established session 0x141584facc80006 with
negotiated timeout 40000 for client /10.1.156.128:53702
(org.apache.zookeeper.server.NIOServerCnxn)
[2013-09-26 14:21:42,849] INFO Closing socket connection to /10.1.156.128.
(kafka.network.Processor)
[2013-09-26 14:21:42,958] INFO Closing socket connection to /10.1.156.128.
(kafka.network.Processor)
[2013-09-26 14:21:43,068] INFO Closing socket connection to /10.1.156.128.
(kafka.network.Processor)
[2013-09-26 14:21:43,177] INFO Closing socket connection to /10.1.156.128.
(kafka.network.Processor)
－－－－－－－－－－－－－－－－－－
时金魁
搜狐新闻，先知道
座机：010-62728758
邮箱：[email protected]<mailto:[email protected]>
地址：北京市海淀区王庄路1号清华同方
科技广场D座西楼8层 100086
搜狐移动新媒体中心
[cid:[email protected]]
