yue li

和楼上同问

I have the similar scene， just like : mongo(source) collections -> elasticsearch(sink) indicies

just like mongo-connecotr's support "namespace_mapping" : index_name.* => *.type_name