Module stream

Manage internal and public Kafka streams

Module that contains functions to manage internal and public Kafka streams.

API methods

• create_internal_stream(id, configuration)
• create_public_stream(id, configuration)
• delete_internal_stream(id)
• delete_public_stream(id)
• get_internal_stream(id) -> stream
• get_internal_streams() -> [stream]
• get_public_stream(id) -> stream
• get_public_streams() -> [stream]
• get_stream_ids() -> [id]