Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> kafka connect error


Copy link to this message
-
Re: kafka connect error
It seems you have turned on security on your zookeeper cluster. Which kafka
client is this log from? Could you send the code snippet that reproduces
this behavior? The kafka server side log seems fine.

Thanks,
Neha
On Sep 25, 2013 11:23 PM, "Shi JinKui(无线事业部)" <[EMAIL PROTECTED]>
wrote:

>  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]
> 地址:北京市海淀区王庄路1号清华同方****
>
> 科技广场D座西楼8层 100086
> 搜狐移动新媒体中心 ****
>
>
> [image: cid:[EMAIL PROTECTED]3D10]****
>
> ** **

 
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB