pswamp.streaming.kafka_extras.utils

Functions

create_topic(kafka_kwargs, name[, num_partitions, ...])
delete_topics(kafka_kwargs, topic_names)
get_last_message_from_topic(kafka_kwargs, topic)
consumer_seek_relative_offset(consumer, relative_offset)

Module Contents

pswamp.streaming.kafka_extras.utils.create_topic(kafka_kwargs, name, num_partitions=1, replication_factor=1, **topic_kwargs)

pswamp.streaming.kafka_extras.utils.delete_topics(kafka_kwargs, topic_names)

pswamp.streaming.kafka_extras.utils.get_last_message_from_topic(kafka_kwargs, topic)

pswamp.streaming.kafka_extras.utils.consumer_seek_relative_offset(consumer, relative_offset)