[PM] Adds group-id to Kafka consumer in agent