lib.sedna.datasources.kafka.producer

Module Contents

Classes

Producer

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

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

Bases: sedna.datasources.kafka.Client

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

connect(boostrap_servers)

publish_data_synchronous(data, topic='default')

publish_data_asynchronous(data, topic='default')

on_send_success(record_metadata)

on_send_error(excp)

close()