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(boostrap_servers)

get_topics()

subscribe(topic)

consume_messages()

consume_messages_poll()

pause()

resume()

close()