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%)
