To subscribe

Dear Apache Kafka, I have couple of questions on Kafka server cluster. I am working on Kafka project and maintaining Kafka brokers are too difficult due to continues failures. Please add me to subscribe Apache Kafka user list. Thanks, Rafeeq S (Inspire to work on Kafka)

Kafka Broker frequent shutdown with exception

Hi I am using kafka 0.8.1 version and facing frequent issue when *kafka broker* startup/restart such as: *1.Whenever Kafka Broker restarted it gets shutdown and throws following error in all Broker nodes.* java.io.EOFException: Received -1 when reading from channel, socket has likely been clos

Re: Kafka Broker frequent shutdown with exception

le hosts something else > is going on. > > Cheers, Robert > > p.s., Same thing applies for the zookeeper-server-stop.sh script. > > > On Mon, Jun 2, 2014 at 10:23 AM, rafeeq s wrote: > > > Hi > > > > I am using kafka 0.8.1 version and facing freq

Re: Kafka Broker frequent shutdown with exception

s with PID 3026. > > Cheers, Robert > > > On Mon, Jun 2, 2014 at 11:04 PM, rafeeq s wrote: > > > Thanks Robert, > > > > For #2 Yes Robert, I am using kafka-server-stop.sh script to stop Brokers > > and it all resides on same Host with differen

How to delete Topic ?

I am using Kafka 0.8.1 and I tried to execute Topic delete command but still Topic list showing that specific Topic. Topic Delete commad which i used: *bin/kafka-topics.sh --zookeeper zk_host:port/chroot --delete --topic my_topic_name* How can i verify that my_topic is deleted ? Is there specif

How to delete Topic in kafka 0.8.1 ?

I am using Kafka 0.8.1 and I tried to execute Topic delete command but still Topic list showing that specific Topic. Topic Delete commad which i used: *bin/kafka-topics.sh --zookeeper zk_host:port/chroot --delete --topic my_topic_name* How can i verify that my_topic is deleted ? Is there specif

Re: How to delete Topic in kafka 0.8.1 ?

CS Games <http://csgames.org> 2014 > Jeux de Génie <http://www.jdgets.com/> 2011 à 2014 > Argentier Fraternité du Piranha <http://fraternitedupiranha.com/> > 2012-2014 > Comité Organisateur Olympiades ÉTS 2012 > Compétition Québécoise d'Ingénierie 2012 - Compétition S

Re: Kafka Broker frequent shutdown with exception

Hi Robert, I tried *kill -SIGTERM * comand to stop Kafka Broker but it shutdown all other brokers as well. Can you please suggest me, How can I avoid stopping other brokers ? Is there any configuration changes required ? Regards, Rafeeq S On Tue, Jun 3, 2014 at 9:40 AM, Robert Hodges

No partition metadata for topic due to kafka.common.LeaderNotAvailableException

Hi , I am using kafka 0.8.1 version and I am getting *LeaderNotAvailableException * frequently. All brokers are up and running well. Note: Recently I have delete a topic. after deleting topic i tried with new topic but also it giving error as LeaderNotAvailableException. Please help to resolve t

How to upgrade Kafka 0.8.1 to 0.8.1.1

I have planned to upgrade Kafka version from 0.8.1 to 0.8.1.1 due major bugs. Is there any procedure link to upgrade Kafka 0.8.1 to 0.8.1.1 ? Please share details to upgrade kafka 0.8.1.1. Thanks in Advance,

Re: How to upgrade Kafka 0.8.1 to 0.8.1.1

t;http://www.jdgets.com/> 2011 à 2014 > Argentier Fraternité du Piranha <http://fraternitedupiranha.com/> > 2012-2014 > Comité Organisateur Olympiades ÉTS 2012 > Compétition Québécoise d'Ingénierie 2012 - Compétition Senior > > > On 4 June 2014 05:29, rafeeq s wrote

Steps to run Kafka 0.8.1 on Windows using cmd prompt ?

e not supported using above post and its specific to 0.8.0. is there any specific steps/procedure to run kafka 0.8.1 on windows machine. Thanks in advance! Regards, Rafeeq S *(“What you do is what matters, not what you think or say or plan.” )*

SimpleConsumer kafka.api.OffsetRequest.LatestTime() not working ?

below simpleconsumer example: https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example Regards, Rafeeq S *(“What you do is what matters, not what you think or say or plan.” )*

Re: SimpleConsumer kafka.api.OffsetRequest.LatestTime() not working ?

Thanks to all. LatestTime() is working as expected. Regards, Rafeeq S *(“What you do is what matters, not what you think or say or plan.” )* On Wed, Jun 18, 2014 at 8:40 PM, Supun Kamburugamuva wrote: > Hi Refeeq, > > I'm using the LatestTime() and it is working. >

SimpleConsumer dynamic read from all partition ?

I am trying to consume kafka messages from all partitions(dynamically assign all partitions) using simpleConsumer. Is there a way to read messages dynamically from *all partitions* using SimpleConsumer ? Thanks in advance! Regards, Rafeeq S *(“What you do is what matters, not what you think

How to use kafka as flume source.

Hi, We are planning to use kafka as *flume source*. Please advice me, how to use kafka as source in flume. please share if there is any best example of *flume- kafka source- hdfs sink*. Regards, Rafeeq S *(“What you do is what matters, not what you think or say or plan.” )*

Re: How to use kafka as flume source.

Thanks. But above link example uses flume-ng <https://github.com/apache/flume> to communicate with *kafka 0.7,2 <http://kafka.apache.org/07/quickstart.html>*. I am using *kafka 0.8.1*. Please advice an example of flume-ng with kafka 0.8.1. Thanks in advance Regards, Rafeeq S *(“Wh