You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by "Shi JinKui (无线事业部)" <ji...@sohu-inc.com> on 2013/09/26 08:23:16 UTC

kafka connect error

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

[cid:image001.jpg@01CE354F.76A13D10]


Re: kafka connect error

Posted by Neha Narkhede <ne...@gmail.com>.
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(无线事业部)" <ji...@sohu-inc.com>
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
> 邮箱:jinkuishi@sohu-inc.com
> 地址:北京市海淀区王庄路1号清华同方****
>
> 科技广场D座西楼8层 100086
> 搜狐移动新媒体中心 ****
>
>
> [image: cid:image001.jpg@01CE354F.76A13D10]****
>
> ** **
>