[tabsdatak.connectors]
stream_src_kafka = tabsdatak.conn.kafka._stream_plugin:KAFKA_STREAM_SRC
