Skip to content

Add an option to enhance the Headers to contain the consumer's group id #1026

@garyrussell

Description

@garyrussell

When the same listener is used for multiple groups, it would be useful if the application could have access to which group a record came from.

By adding the group to the ConsumerRecord.headers() it will be mapped, and available in the @KafkaListener as @Header parameter.

Metadata

Metadata

Assignees

Type

No type

Projects

No projects

Milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions