Skip to content

Default Kafka (aiokafka) consumer group #1867

Answered by Lancetnik
SirSilver asked this question in Q&A
Discussion options

You must be logged in to vote

@SirSilver sorry, we have no ability to set consumer group to all broker / routers
But you can add it by yourself easely: just add required params to broker & router __init__ and then set subscribers' consumer group as group or self.group - https://github.com/airtai/faststream/blob/main/faststream/kafka/broker/registrator.py#L1602

Replies: 1 comment 1 reply

Comment options

You must be logged in to vote
1 reply
@SirSilver
Comment options

Answer selected by SirSilver
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Category
Q&A
Labels
None yet
2 participants