You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@inlong.apache.org by do...@apache.org on 2022/09/08 06:16:32 UTC

[inlong] branch master updated (e2c31ab57 -> e857767ab)

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


    from e2c31ab57 [INLONG-5824][Manager] Fix the broken logging due to log4j conflicts (#5826)
     add e857767ab [INLONG-5796][SDK] Optimize fetcher builders (#5800)

No new revisions were added by this update.

Summary of changes:
 ...ilder.java => AbstractTopicFetcherBuilder.java} |  35 +++++--
 .../inlong/sdk/sort/api/MultiTopicsFetcher.java    |  11 +-
 .../inlong/sdk/sort/api/SingleTopicFetcher.java    |   5 +
 .../inlong/sdk/sort/api/SortClientConfig.java      |  22 +++-
 .../apache/inlong/sdk/sort/api/TopicFetcher.java   |   6 ++
 .../inlong/sdk/sort/api/TopicFetcherBuilder.java   |  92 +++++++++++++++--
 .../sort/fetcher/kafka/AckOffsetOnRebalance.java   | 101 +++++++++++++++---
 .../fetcher/kafka/KafkaMultiTopicsFetcher.java     | 115 +++++++++++----------
 ...lder.java => KafkaTopicFetcherBuilderImpl.java} |  40 +++++--
 .../fetcher/pulsar/PulsarMultiTopicsFetcher.java   |  25 +++--
 ...der.java => PulsarTopicFetcherBuilderImpl.java} |  40 +++++--
 ...ilder.java => TubeTopicFetcherBuilderImpl.java} |  15 ++-
 .../sdk/sort/manager/InlongSingleTopicManager.java |   6 +-
 13 files changed, 393 insertions(+), 120 deletions(-)
 rename inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/{SingleTopicFetcherBuilder.java => AbstractTopicFetcherBuilder.java} (59%)
 rename inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/fetcher/kafka/{KafkaSingleTopicFetcherBuilder.java => KafkaTopicFetcherBuilderImpl.java} (57%)
 rename inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/fetcher/pulsar/{PulsarSingleTopicFetcherBuilder.java => PulsarTopicFetcherBuilderImpl.java} (58%)
 rename inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/fetcher/tube/{TubeSingleTopicFetcherBuilder.java => TubeTopicFetcherBuilderImpl.java} (78%)