BroadwayKafka (BroadwayKafka v0.4.4)

View Source

Helpers for BroadwayKafka.

You can find the Broadway producer in BroadwayKafka.Producer.

Summary

Functions

update_topics(name, topics)

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

Functions

update_topics(name, topics)

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