New-Consumer group not showing up

2016-03-24 Thread Ryan Phillips
Greetings, I’m attempting to use the New Consumer in my project (0.9.0.1), and it appears to be working nicely. The issue that I am seeing is that the group.id is not showing up within: kafka-consumer-groups.sh —bootstrap-server kafka0.local:9092,kafka1.local:9092 —new-consumer —list The command

Re: New-Consumer group not showing up

2016-03-24 Thread Ryan Phillips
I am only assigning this consumer one partition to listen to. Perhaps that is where the issue lies, because the kafka-console-consumer's group id (listening on all partitions) shows up correctly within the kafka-consumer-groups command. On Thu, Mar 24, 2016 at 6:59 PM, Ryan Phillips

Re: New-Consumer group not showing up

2016-03-25 Thread Ryan Phillips
u should > see the group listed in the output of consumer-groups.sh. > > -Jason > > On Thu, Mar 24, 2016 at 7:37 PM, craig w wrote: > >> Did you subscribe and poll? I believe your consumer group won't show up >> until it has been assigned one or more partitio

Re: Listener for Lead broker change for topic partition in the 0.9.* consumer

2016-04-01 Thread Ryan Phillips
I believe the way this works is that you will get a UnknownTopicOrPartitionException on a poll. On Fri, Apr 1, 2016 at 1:36 PM, Wang, Howard wrote: > Hi, > > I have a use case where I need to be notified about the change of lead > broker for my topic partitions. I’m using the new API 0.9.0. Is t