What's Changed
Now, FastStream provides users with the ability to pass the config dictionary to confluent-kafka-python for greater customizability. The following example sets the parameter topic.metadata.refresh.fast.interval.ms's value to 300 instead of the default value 100 via the config parameter.
from faststream import FastStream
from faststream.confluent import KafkaBroker
config = {"topic.metadata.refresh.fast.interval.ms": 300}
broker = KafkaBroker("localhost:9092", config=config)
app = FastStream(broker)- Update Release Notes for 0.5.11 by @faststream-release-notes-updater in #1511
- docs: update filters example by @Lancetnik in #1516
- Add config param to pass additional parameters to confluent-kafka-python by @kumaranvpl in #1505
Full Changelog: 0.5.11...0.5.12