faststream
faststream copied to clipboard
Ability to configure topic params in confluent create_topics
Currently if the topic doesn't exists we create it with num_partitions
and replication_factor
set to 1
- https://github.com/airtai/faststream/blob/7c069db7ff28bb43451aaa4dbffd84e8c261567a/faststream/confluent/client.py#L438-L452. We should provide a way for users to configure the num_partitions
and replication_factor
for each topic if possible.
Based on https://github.com/airtai/faststream/discussions/1821