View Source BroadwayKafka (BroadwayKafka v0.4.1)
Helpers for BroadwayKafka.
You can find the Broadway producer in BroadwayKafka.Producer.
Link to this section Summary
Functions
Sequentially updates topics in all Broadway producers in the
pipeline given by name.
Link to this section Functions
Sequentially updates topics in all Broadway producers in the
pipeline given by name.
examples
Examples
BroadwayKafka.update_topics(MyBroadway, ["topic_a", "topic_b"])
:ok
BroadwayKafka.update_topics(MyBroadway, [])
:ok