Also including kafka user mailing list.
Has anybody seen this error? Any idea to fix it?
Thanks
Subhash Agrawal.
From: Subhash Agrawal
Sent: Wednesday, July 06, 2016 5:12 PM
To: 'dev@kafka.apache.org'
Subject: Error after restarting kafka broker
Hi All,
I am running kafka broker (0.10
Hi All,
I am running kafka broker (0.10.0 version) in standalone mode (Single kafka
broker in the cluster).
After couple of restart, I see this error during embedded kafka startup, even
though it does not seem to be causing any problem.
Is there any way I can avoid this error?
Thanks
Subhash
at
org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:134)
Please let me know what I am missing.
Thanks
Subhash Agrawal.
From: Subhash Agrawal
Sent: Monday, June 20, 2016 4:20 PM
To: dev@kafka.apache.org; 'us...@kafka.apache.org'
Subject: Error while sending message t
(Y/N)? y
Any idea what should I look into?
Thanks
Subhash Agrawal
(kafkaConfig); with kafka 0.10.0? if not, how
can I pass
these parameters? It used to work with kafka 0.7.1.
Thanks
Subhash Agrawal
-Original Message-
From: isma...@gmail.com [mailto:isma...@gmail.com] On Behalf Of Ismael Juma
Sent: Thursday, June 16, 2016 1:38 AM
To: dev@kafka.apache.org
Subject
same process. It must
be some kafka specific issue.
Subhash Agrawal
-Original Message-
From: Guozhang Wang [mailto:wangg...@gmail.com]
Sent: Wednesday, June 15, 2016 3:42 PM
To: dev@kafka.apache.org
Subject: Re: Embedding zookeeper and kafka in java process.
It seems "scala.Match
is not able
to add the newly created kafka instance. Have you seen this error earlier? I
have only single node kafka.
Let me know if you have any suggestions. I will really appreciate any help on
this.
Thanks
Subhash Agrawal.
[2016-06-15 13:39:39,616] INFO [Logserver_Starter] Registered broker
kafka externally, then I don't see this
error.
Thanks
Subhash A.
From: Subhash Agrawal
Sent: Wednesday, June 08, 2016 12:40 PM
To: 'us...@kafka.apache.org'
Subject: Migrating from 07.1 .100
Hi,
I am currently using Kafka 0.7.1 without zookeeper. We have single node kafka
ser