BroadwayKafka (BroadwayKafka v0.4.4)

Helpers for BroadwayKafka.

You can find the Broadway producer in BroadwayKafka.Producer.

Summary

Sequentially updates topics in all Broadway producers in the pipeline given by name.

Sequentially updates topics in all Broadway producers in the pipeline given by name.

BroadwayKafka.update_topics(MyBroadway, ["topic_a", "topic_b"])
:ok

BroadwayKafka.update_topics(MyBroadway, [])
:ok