kafka_connector .. automodule:: kafka_connector.avro_loop_consumer :members: .. automodule:: kafka_connector.avro_loop_producer :members: