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 <[email protected]> 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?
>
