View Source BroadwayKafka (BroadwayKafka v0.3.5)

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

Link to this function

update_topics(name, topics)

View Source

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