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 邮箱:jinkui...@sohu-inc.com<mailto:jinkui...@sohu-inc.com> 地址:北京市海淀区王庄路1号清华同方 科技广场D座西楼8层 100086 搜狐移动新媒体中心 [cid:image001.jpg@01CE354F.76A13D10]