geowatchutil.client.geowatch_client_kafka module¶

class geowatchutil.client.geowatch_client_kafka.GeoWatchClientKafka(topic_prefix='', host=None)[source]¶

Bases: geowatchutil.client.base.GeoWatchClientTopic

check_topic_exists(topic, timeout=5, verbose=True)[source]¶

close()[source]¶

create_topic(topic, shards=1, timeout=5, verbose=True)[source]¶

delete_topic(topic, timeout=5, verbose=True)[source]¶

delete_topics(topics, ignore_errors=True, timeout=5, verbose=True)[source]¶

list_topics(limit=100, verbose=True)[source]¶