View Source BroadwayKafka (BroadwayKafka v0.4.3)

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

Link to this function

update_topics(name, topics)

View Source

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