lib.sedna.datasources.kafka.consumer

Module Contents

Classes

Consumer

Helper class that provides a standard way to create an ABC using

class lib.sedna.datasources.kafka.consumer.Consumer(address=['localhost'], port=[9092], group_id='default', consumer_timeout_ms=250)

Bases: sedna.datasources.kafka.Client

Helper class that provides a standard way to create an ABC using inheritance.

connect(self, boostrap_servers)

get_topics(self)

subscribe(self, topic)

consume_messages(self)

consume_messages_poll(self)

pause(self)

resume(self)

close(self)