geowatchutil.channel.geowatch_channel_kafka module

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

Bases: geowatchutil.channel.base.GeoWatchChannelTopic

close()

classmethod decode(message)

classmethod encode(message)

get_messages_raw(count, block=True, timeout=5)

group = None

send_message(message)

send_messages(messages)