Hi
I am using the 0811 Kafka High level consumer and I have configured "
consumer.timeout.ms" to a value that is not -1, say 5000ms.
I create the consumer iterator and invoke hasNext() method on it.
Irrespective of whether kafka broker was shutdown or there was no message
written to kafka, I see
Hey! Did anyone get a chance to read this?
Thanks!!
On Wed, Jan 28, 2015 at 6:21 PM harikiran wrote:
>
> Hi
>
> I am using the 0811 Kafka High level consumer and I have configured "
> consumer.timeout.ms" to a value that is not -1, say 5000ms.
>
> I create t
Thanks Guozhang and Jun for your replies.
On Wed, Feb 4, 2015 at 4:07 PM, harikiran wrote:
> Hey! Did anyone get a chance to read this?
>
> Thanks!!
> On Wed, Jan 28, 2015 at 6:21 PM harikiran wrote:
>
>>
>> Hi
>>
>> I am using the 0811 Kafka Hi
Hi Michal,
Are you able to write and read from the kerberized Kafka setup using the
Kafka Console Producer and Consumer?
I am taking a look at your configuration files.
Thanks
Hari.
On Thu, Mar 3, 2016 at 8:09 AM Jonathan Natkins
wrote:
> Hey Michal,
>
> I'm cc'ing the StreamSets user list, w
LAINTEXT://:9092
advertised.listeners=SASL_PLAINTEXT://:9092
host.name=kafka
advertised.host.name=kafka
'kafka' is the hostname on which the Kafka broker is running in my setup.
There is an entry for this host in '/etc/hosts' on the node where
StreamSets is running.
Thanks
Hari.
On T
c[16307](info): TGS_REQ (4 etypes {18
> 17 16 23}) 10.xxx.xxx.72
> <http://www.google.com/url?q=http%3A%2F%2F10.111.159.72&sa=D&sntz=1&usg=AFQjCNGfeOUI5N_QC-VKyS_d9ouhNTfYpQ>:
> ISSUE: authtime 1457103631, etypes {rep=18 tkt=18 ses=18},
> client/10.xxx.xxx...@hdpcybersecac
