geowatchutil.channel.geowatch_channel_kafka module

class geowatchutil.channel.geowatch_channel_kafka.GeoWatchChannelKafka(client, topic, mode, num_procs=1, group=None)[source]

Bases: geowatchutil.channel.base.GeoWatchChannelTopic

close()[source]
classmethod decode(message)[source]
classmethod encode(message)[source]
get_messages_raw(count, block=True, timeout=5)[source]
group = None
send_message(message)[source]
send_messages(messages)[source]