daqd_kafka_connector_rs