Thanks Jason and Craig.
Jason, that is exactly correct. I am using the simple consumer mode.
Is there an easy way to find out the lag for consumers using the
Simple Consumer mode?
Regards,
Ryan
On Fri, Mar 25, 2016 at 11:47 AM, Jason Gustafson wrote:
> Hey Ryan,
>
> Sounds like you might be usi
Hey Ryan,
Sounds like you might be using the so-called "simple consumer" mode. If you
use assign() to give your consumer a specific partition, you're not
actually using a consumer group, so there won't be any coordination with
other consumers. If you use subscribe() on the other hand, then you sho
Did you subscribe and poll? I believe your consumer group won't show up
until it has been assigned one or more partitions.
On Mar 24, 2016 9:48 PM, "Ryan Phillips" wrote:
> I am only assigning this consumer one partition to listen to. Perhaps
> that is where the issue lies, because the kafka-cons
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 wrote:
> Gree
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
