Apache Pinot

Is there a way to specify the group id for Kafka realtime ingestion? What’s the ingestion config key should be?

low-level consumer mode is per-partition based, so no need to specify group-id

Is there a way to monitor the latency for consuming when using the low-level consumer?

if u want to specify the group id you can try:
```stream.[streamType].consumer.prop.group.id```


basically whatever after `stream.[streamType].consumer.prop.` will be put into kafka consumer configs

I see, so the group id has no effect on low-level consumer?

no, but it may help report the consuming latency

just you cannot use it to reset the consumer

I specified the group id using `stream.kafka.consumer.prop.group.id` , it’s not working, that group id is not shown in kafka.

I see, then in that case, we need to implement the API internally to fetch the delay