feat(gateway): Set consumer group ID for kafka/confluent consume#5624
Open
lena-larionova wants to merge 1 commit into
Open
feat(gateway): Set consumer group ID for kafka/confluent consume#5624lena-larionova wants to merge 1 commit into
lena-larionova wants to merge 1 commit into
Conversation
✅ Deploy Preview for kongdeveloper ready!
To edit notification comments on pull requests, go to your Netlify project configuration. |
Contributor
There was a problem hiding this comment.
Pull request overview
Adds new plugin example configurations for Kafka Consume and Confluent Consume that demonstrate setting a stable consumer group ID (either manually or derived from an authenticated Kong Gateway Consumer), supporting Kafka brokers/managed services that enforce consumer-group ACLs.
Changes:
- Added a Kafka Consume example for a fixed (operator-chosen) consumer group ID (
manualmode). - Added a Kafka Consume example that sets consumer group ID based on the authenticated Consumer (
kong_consumermode). - Added equivalent examples for Confluent Consume, including required Confluent Cloud credentials.
Reviewed changes
Copilot reviewed 4 out of 4 changed files in this pull request and generated no comments.
| File | Description |
|---|---|
| app/_kong_plugins/kafka-consume/examples/consumer-group-manual.yaml | New example showing a fixed, manually specified consumer group ID for ACL-enforced clusters. |
| app/_kong_plugins/kafka-consume/examples/consumer-group-kong-consumer.yaml | New example showing consumer-group derivation from the authenticated Kong Gateway Consumer. |
| app/_kong_plugins/confluent-consume/examples/consumer-group-manual.yaml | New Confluent Cloud variant of the fixed/manual consumer group ID example (includes API key/secret). |
| app/_kong_plugins/confluent-consume/examples/consumer-group-kong-consumer.yaml | New Confluent Cloud variant of the per-Consumer consumer group ID example (includes API key/secret). |
tomek-labuk
approved these changes
Jun 18, 2026
tomek-labuk
left a comment
tomek-labuk
left a comment
Contributor
There was a problem hiding this comment.
Looks good, just a side note: should we rethink our convention of how we frame requirements (instead of 'You have x y z' just state 'x y z' directly)?
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Description
Kafka Consume and Confluent Consume can now set a consumer group ID instead of generating one. This is necessary for brokers that enforce ACLs.
Added plugin examples; I don't think it needs a reference section, but could be convinced.
Examples for https://github.com/Kong/kong-technical-enablement/tree/main/api-gateway/3.15/kafka-consume-consumer-group-id.
Preview Links