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)[source]

Bases: sedna.datasources.kafka.Client

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

connect(self, boostrap_servers)[source]
get_topics(self)[source]
subscribe(self, topic)[source]
consume_messages(self)[source]
consume_messages_poll(self)[source]
pause(self)[source]
resume(self)[source]
close(self)[source]