imvan commented on pull request #2182: URL: https://github.com/apache/incubator-inlong/pull/2182#issuecomment-1015401813
> It's a new interface that **Sort Stand-alone** acquire cluster config including id params and sink params. Id params is the params of upstream data store such as the topic of kafka and pulsar which Sort Stand-alone consume from. While sink params is the dispatch type of Sort Stand-alone Sink, which determine which kafka or pulsar cluster the produced data send to. hence it's something like kafka zklist, brokerlist, pulsar serviceUrl, token.. Due to the diversity of upstream data store type and downstrem sink type, there must be many tables to maintain those params of different type of sources and sinks. Most of files are auto generated by Mybatis code generator, such as those xxxMapper.java and xxxMapper.xml What we need to care about are those xxxxServiceImpl.java , espacially **SortClusterConfigServiceImpl.java** which is the core logic that how to generate a valid **ClusterConfig** -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
