lib.sedna.datasources.kafka

Submodules

• lib.sedna.datasources.kafka.consumer
• lib.sedna.datasources.kafka.kafka_manager
• lib.sedna.datasources.kafka.producer

Package Contents

Classes

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

class lib.sedna.datasources.kafka.Client(address=['localhost'], port=[9092])

Bases: abc.ABC

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

abstract connect(bootstrap_servers)

hardened_connect()

class lib.sedna.datasources.kafka.AdminClient(address=['localhost'], port=[9092])

Bases: Client

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

create_topics(topics, num_partitions=1, replication_factor=1)

delete_topics(topics, num_partitions=1, replication_factor=1)