Helpers for BroadwayKafka.
You can find the Broadway producer in BroadwayKafka.Producer.
Summary
Functions
Sequentially updates topics in all Broadway producers in the
pipeline given by name.
Functions
@spec update_topics(Broadway.name(), Enumerable.t(String.t())) :: :ok
Sequentially updates topics in all Broadway producers in the
pipeline given by name.
Examples
BroadwayKafka.update_topics(MyBroadway, ["topic_a", "topic_b"])
:ok
BroadwayKafka.update_topics(MyBroadway, [])
:ok