Re: Consumer blocked when auth failed.

2017-07-24 Thread 陈江枫
Hi, I intentionally use the wrong credential, get the following log: *java.net.ConnectException: Connection refused* * at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)* * at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)* * at org.apache.kafka.common.network.Pla

Re: Consumer blocked when auth failed.

2017-07-19 Thread Jason Gustafson
What log level do you have configured? You might bump up to DEBUG or TRACE and see if anything stands out. -Jason On Tue, Jul 18, 2017 at 7:59 PM, 陈江枫 wrote: > Hi, > > I was integrating Kafka with Spark, using DirectStream, when my > authentication fail, the stream just blocked. No log, no exc

Consumer blocked when auth failed.

2017-07-18 Thread 陈江枫
Hi, I was integrating Kafka with Spark, using DirectStream, when my authentication fail, the stream just blocked. No log, no exceptions were thrown. Could some one help to address such situtation