RE: Error after restarting kafka broker

2016-07-07 Thread Subhash Agrawal
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.0 version

Error after restarting kafka broker

2016-07-06 Thread Subhash Agrawal
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

RE: Error while sending message to Kafka broker on SSL with Kafka 0.10.0.0

2016-06-21 Thread Subhash Agrawal
va:229) 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 to Kafka broker

Error while sending message to Kafka broker on SSL with Kafka 0.10.0.0

2016-06-20 Thread Subhash Agrawal
(Y/N)? y Any idea what should I look into? Thanks Subhash Agrawal

RE: Embedding zookeeper and kafka in java process.

2016-06-16 Thread 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

RE: Embedding zookeeper and kafka in java process.

2016-06-15 Thread Subhash Agrawal
in 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

Embedding zookeeper and kafka in java process.

2016-06-15 Thread Subhash Agrawal
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

RE: Migrating from 07.1 .100

2016-06-13 Thread Subhash Agrawal
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 server. To enhance