I asked simply because I would like to monitor the topic consumed by our
samza job using tools like this:
https://github.com/quantifind/KafkaOffsetMonitor
On Tue, Mar 15, 2016 at 9:13 PM, Jagadish Venkatraman <
jagadish1...@gmail.com> wrote:
> Hi David,
>
> Samza is using the simple consumer - I'm not aware of a notion of group id.
> Others will comment on that.
>
> As far as I know, the client id for a particular consumer instance is
> defined by a combination of the job name, the current timestamp and a
> sequence number.
>
> val clientId = KafkaUtil.getClientId("samza-consumer", config)
>
> KafkaUtil.getClientId has this logic.
>
> I'm curious about your usecase as to why you are interested in inspecting
> this information?
>
> Thanks,
> Jagadish
>
> On Tuesday, March 15, 2016, David Yu <david...@optimizely.com> wrote:
>
> > Our samza job is consuming from a Kafka topic. AFAIU, samza will auto
> > assign the job a consumer group id and client id. However, I'm not able
> to
> > see that showing up under zookeeper. Am I missing something?
> >
>
