Re: Cannot connect to Kafka from outside of EC2

Could you use the topic tools "--describe" to check if the topic Test's partitions leaders are available? http://kafka.apache.org/documentation.html#basic_ops_add_topic Guozhang On Fri, Oct 24, 2014 at 2:43 PM, Sameer Yami wrote: > That is not the case. > This detailed error is below. Due to t

Re: Explicit topic creation and topic metadata availability

Hi Stevo, Sorry for the late reply. Yes, you have to use ZKStringSerializer when initializing zkClient. However this is not related to key.serializer.class of the producer (not the KafkaProducer, which is the new producer that does not need any key serializer any more). key.serializer.class and

Re: kafka.common.ConsumerRebalanceFailedException

Can you see if the workarounds mentioned here for failed rebalance attempts is useful? On Fri, Oct 24, 2014 at 11:22 AM, Mohit Anchlia wrote: > I am seeing following exception, don't understand the issu

Re: High Level Consumer Iterator IllegalStateException Issue

Can you provide the steps to reproduce this issue? On Fri, Oct 24, 2014 at 6:11 PM, Bhavesh Mistry wrote: > I am using one from the Kafka Trunk branch. > > Thanks, > > Bhavesh > > On Fri, Oct 24, 2014 at 5:24 PM, Neha Narkhede > wrote: > > > Which version of Kafka are you using on the consumer?

Re: Delete Specific Message from a Topic (partition)

Thanks for your response. I agree on sending messages to other new topic and thats what I am doing now. The reason of asking deleting of messages from log : Say I have a topic "InitialState_topic1" where one consumer group mygroupID1 is reading and is sending messages to new topic "InprogressState_

Re: Delete Specific Message from a Topic (partition)

Have group 1 act like a filter, publish to a new topic all messages that group 2 should process and then have group 2 actually consume only new topic. Kind regards, Stevo Slavic On Oct 26, 2014 2:36 AM, "Srinivas Reddy Kancharla" wrote: > Hi, > > I have a scenario where I produce messages for a