[GitHub] [inlong] dockerzhang commented on issue #5042: [Feature] Add Apache Doris Extract Node for Agent

dockerzhang commented on issue #5042: URL: https://github.com/apache/inlong/issues/5042#issuecomment-1223641292 In most usage scenarios, Doris is more used for storage than collection. So this issue is temporarily closed -- This is an automated message from the Apache Git Service. To resp

[GitHub] [inlong] yunqingmoswu commented on a diff in pull request #5638: [INLONG-5637][Sort] Fix kafka load node npe error

yunqingmoswu commented on code in PR #5638: URL: https://github.com/apache/inlong/pull/5638#discussion_r952228589 ## inlong-sort/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/FlinkKafkaProducer.java: ## @@ -928,19 +928,15 @@ public void onCompletion(RecordMeta

[GitHub] [inlong] pocozh opened a new pull request, #5641: [INLONG-5437][SDK] Support initializing SDK(cpp) by ClientConfig object

pocozh opened a new pull request, #5641: URL: https://github.com/apache/inlong/pull/5641 ### Prepare a Pull Request *(Change the title refer to the following example)* - [INLONG-5437][SDK] Support initializing SDK(cpp) by ClientConfig object *(The following *XYZ* should be re

[inlong] branch release-1.3.0 created (now 99189beda)

This is an automated email from the ASF dual-hosted git repository. zirui pushed a change to branch release-1.3.0 in repository https://gitbox.apache.org/repos/asf/inlong.git at 99189beda [INLONG-4764][Sort] Import sort end2end unit test with group file input (#5627) No new revisions wer

[GitHub] [inlong] github-actions[bot] commented on issue #5643: There is a vulnerability in Apache Flume 1.9.0,upgrade recommended

github-actions[bot] commented on issue #5643: URL: https://github.com/apache/inlong/issues/5643#issuecomment-1223715669 Thanks a lot for opening your first issue with us! 🧡 We'll get back to you shortly! ⏳ -- This is an automated message from the Apache Git Service. To respond to the mess

[GitHub] [inlong] dockerzhang merged pull request #5641: [INLONG-5437][SDK] Support initializing SDK(cpp) by ClientConfig object

dockerzhang merged PR #5641: URL: https://github.com/apache/inlong/pull/5641 -- 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: commits-unsubscr...@inlong.

[inlong] branch master updated: [INLONG-5437][SDK] Support initializing SDK(cpp) by ClientConfig object (#5641)

This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/inlong.git The following commit(s) were added to refs/heads/master by this push: new c9a640d4c [INLONG-5437][SDK] Support initia

[inlong] branch release-1.3.0 updated: [INLONG-5437][SDK] Support initializing SDK(cpp) by ClientConfig object (#5641)

This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch release-1.3.0 in repository https://gitbox.apache.org/repos/asf/inlong.git The following commit(s) were added to refs/heads/release-1.3.0 by this push: new 05a94af45 [INLONG-5437][SDK]

[GitHub] [inlong] leezng opened a new pull request, #5649: [INLONG-5648][Dashboard] Optimize the create logic, support specifying specific types

leezng opened a new pull request, #5649: URL: https://github.com/apache/inlong/pull/5649 - Fixes #5648 -- 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-mai

[GitHub] [inlong] healchow opened a new pull request, #5651: [INLONG-5650][Manager] Remove the non-null check of the Pulsar adminURL

healchow opened a new pull request, #5651: URL: https://github.com/apache/inlong/pull/5651 ### Prepare a Pull Request - Fixes #5650 ### Motivation Remove the non-null check of the Pulsar adminURL. -- This is an automated message from the Apache Git Service. To

[inlong] branch master updated (c9a640d4c -> 90b678876)

This is an automated email from the ASF dual-hosted git repository. yunqing pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/inlong.git from c9a640d4c [INLONG-5437][SDK] Support initializing SDK(cpp) by ClientConfig object (#5641) add 90b678876 [INLONG

[GitHub] [inlong] yunqingmoswu merged pull request #5638: [INLONG-5637][Sort] Fix kafka load node npe error

yunqingmoswu merged PR #5638: URL: https://github.com/apache/inlong/pull/5638 -- 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: commits-unsubscr...@inlong

[GitHub] [inlong] healchow merged pull request #5651: [INLONG-5650][Manager] Remove the non-null check of the Pulsar adminURL

healchow merged PR #5651: URL: https://github.com/apache/inlong/pull/5651 -- 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: commits-unsubscr...@inlong.apa

[inlong] branch master updated: [INLONG-5650][Manager] Remove the non-null check of the Pulsar adminURL (#5651)

This is an automated email from the ASF dual-hosted git repository. healchow pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/inlong.git The following commit(s) were added to refs/heads/master by this push: new 8f26932c8 [INLONG-5650][Manager] Remove the no

[GitHub] [inlong] woofyzhao commented on issue #4956: [Bug][Manager] Fail to update user info

woofyzhao commented on issue #4956: URL: https://github.com/apache/inlong/issues/4956#issuecomment-1223832798 This issue is already fixed by refactoring the user admin UI -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [inlong] lucaspeng12138 opened a new pull request, #5653: [INLONG-5652][Docker] Fix push aarch64 images script

lucaspeng12138 opened a new pull request, #5653: URL: https://github.com/apache/inlong/pull/5653 ### Prepare a Pull Request [INLONG-5652][Docker] Fix push aarch64 images script - Fixes #5652 ### Motivation [INLONG-5652][Docker] Fix push aarch64 images script ##

[GitHub] [inlong] EMsnap commented on issue #5654: [Release] Create a 1.3.0 branch to release

EMsnap commented on issue #5654: URL: https://github.com/apache/inlong/issues/5654#issuecomment-1223927071 See at: https://github.com/apache/incubator-inlong/tree/release-1.3.0 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

[GitHub] [inlong] dockerzhang merged pull request #5640: [INLONG-5639][Release] Bumped version to 1.4.0-SNAPSHOT

dockerzhang merged PR #5640: URL: https://github.com/apache/inlong/pull/5640 -- 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: commits-unsubscr...@inlong.

[inlong] branch master updated: [INLONG-5639][Release] Bumped version to 1.4.0-SNAPSHOT (#5640)

This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/inlong.git The following commit(s) were added to refs/heads/master by this push: new c1f798c96 [INLONG-5639][Release] Bumped ver

[inlong] 01/02: [INLONG-5637][Sort] Fix kafka load node npe error (#5638)

This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch release-1.3.0 in repository https://gitbox.apache.org/repos/asf/inlong.git commit 98a13686348cb2971fdcafccf0e5d0c5e962a96a Author: Charles <44659300+yunqingmo...@users.noreply.github.com> Aut

[inlong] 02/02: [INLONG-5650][Manager] Remove the non-null check of the Pulsar adminURL (#5651)

This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch release-1.3.0 in repository https://gitbox.apache.org/repos/asf/inlong.git commit 38dfe734f45c76574d3fc1fb83acb4b0aa1d35cf Author: healchow AuthorDate: Tue Aug 23 17:46:13 2022 +0800 [I

[inlong] branch release-1.3.0 updated (05a94af45 -> 38dfe734f)

This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a change to branch release-1.3.0 in repository https://gitbox.apache.org/repos/asf/inlong.git from 05a94af45 [INLONG-5437][SDK] Support initializing SDK(cpp) by ClientConfig object (#5641) new 98a136

[GitHub] [inlong] EMsnap opened a new pull request, #5656: [INLONG-5655][Release] change version in release-1.3.0 to 1.3.0

EMsnap opened a new pull request, #5656: URL: https://github.com/apache/inlong/pull/5656 - Fixes #5655 ### Motivation [INLONG-5655][Release] change version in release-1.3.0 to 1.3.0 ### Modifications [INLONG-5655][Release] change version in release-1.3.0 to 1.3.0

[GitHub] [inlong] vernedeng opened a new pull request, #5659: [INLONG-5623][SDK] Support kafka multi topics fetcher

vernedeng opened a new pull request, #5659: URL: https://github.com/apache/inlong/pull/5659 - Fixes #5623 ### Motivation 1. Introduce **_skiplist_** to maintain the offset commit of each TopicPartitions 2. The costomized msgOffset is different from **_KafkaSingleTopicFe

[GitHub] [inlong] woofyzhao opened a new pull request, #5660: [INLONG-5658][Dataproxy] Fix incorrect script

woofyzhao opened a new pull request, #5660: URL: https://github.com/apache/inlong/pull/5660 ### Prepare a Pull Request *(Change the title refer to the following example)* - Title Example: [INLONG-XYZ][Component] Title of the pull request *(The following *XYZ* should be replac

[GitHub] [inlong] EMsnap opened a new pull request, #5661: [INLONG-5657][Release] Change the tag of Docker images to 1.3.0

EMsnap opened a new pull request, #5661: URL: https://github.com/apache/inlong/pull/5661 - Fixes #5657 ### Motivation [INLONG-5657][Release] Change the tag of Docker images to 1.3.0 ### Modifications [INLONG-5657][Release] Change the tag of Docker images to 1.3.0

[GitHub] [inlong] EMsnap commented on issue #5662: [Release] Publish all 1.3.0 images to docker hub

EMsnap commented on issue #5662: URL: https://github.com/apache/inlong/issues/5662#issuecomment-1223961871 According to the ci_docker.yml, all the Docker images of default and release-x.x.x branchs will be pushed to the Docker Hub automatically. See them here: https://hub.docker.com/u

[GitHub] [inlong] vernedeng commented on a diff in pull request #5625: [INLONG-5621][SDK] Support multi-topic pulsar fetcher

vernedeng commented on code in PR #5625: URL: https://github.com/apache/inlong/pull/5625#discussion_r952521107 ## inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/fetcher/pulsar/PulsarMultiTopicsFetcher.java: ## @@ -0,0 +1,427 @@ +/* + * Licensed to the Apache Softwa

[GitHub] [inlong] healchow merged pull request #5660: [INLONG-5658][DataProxy] Fix incorrect docker script

healchow merged PR #5660: URL: https://github.com/apache/inlong/pull/5660 -- 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: commits-unsubscr...@inlong.apa

[inlong] branch master updated: [INLONG-5658][DataProxy] Fix incorrect docker script (#5660)

This is an automated email from the ASF dual-hosted git repository. healchow pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/inlong.git The following commit(s) were added to refs/heads/master by this push: new 6171a2a7f [INLONG-5658][DataProxy] Fix incorre

[GitHub] [inlong] dockerzhang commented on a diff in pull request #5661: [INLONG-5657][Release] Change the tag of Docker images to 1.3.0

dockerzhang commented on code in PR #5661: URL: https://github.com/apache/inlong/pull/5661#discussion_r952610143 ## docker/publish-by-arch.sh: ## @@ -51,15 +51,15 @@ buildImage() { initTagImageForx86() { SRC_POSTFIX="" DES_POSTFIX="-x86" Review Comment: this file is n

[GitHub] [inlong] leezng merged pull request #5649: [INLONG-5648][Dashboard] Optimize the create logic, support specifying specific types

leezng merged PR #5649: URL: https://github.com/apache/inlong/pull/5649 -- 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: commits-unsubscr...@inlong.apach

[inlong] branch master updated: [INLONG-5648][Dashboard] Optimize the create logic, support specifying specific types (#5649)

This is an automated email from the ASF dual-hosted git repository. leezng pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/inlong.git The following commit(s) were added to refs/heads/master by this push: new 21de72e7a [INLONG-5648][Dashboard] Optimize the

[GitHub] [inlong] GanfengTan opened a new pull request, #5664: [INLONG-5663][Agent] To update data structure for k8s log

GanfengTan opened a new pull request, #5664: URL: https://github.com/apache/inlong/pull/5664 To update data structure and to support SORT in the InLong. - Fixes #5663 ### Motivation For example: "_content_" -->"__content__" "_LogTime" -->"__LogTime__" ### Mo

[GitHub] [inlong] dockerzhang merged pull request #5653: [INLONG-5652][Docker] Fix push aarch64 images script

dockerzhang merged PR #5653: URL: https://github.com/apache/inlong/pull/5653 -- 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: commits-unsubscr...@inlong.

[inlong] branch master updated (21de72e7a -> 2baf658c6)

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 21de72e7a [INLONG-5648][Dashboard] Optimize the create logic, support specifying specific types (#5649) add

[GitHub] [inlong] healchow commented on a diff in pull request #5625: [INLONG-5621][SDK] Support multi-topic pulsar fetcher

healchow commented on code in PR #5625: URL: https://github.com/apache/inlong/pull/5625#discussion_r953292425 ## inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/fetcher/pulsar/PulsarMultiTopicsFetcher.java: ## @@ -0,0 +1,432 @@ +/* + * Licensed to the Apache Softwar

[GitHub] [inlong] healchow commented on a diff in pull request #5625: [INLONG-5621][SDK] Support multi-topic pulsar fetcher

healchow commented on code in PR #5625: URL: https://github.com/apache/inlong/pull/5625#discussion_r953292937 ## inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/fetcher/pulsar/PulsarMultiTopicsFetcher.java: ## @@ -0,0 +1,432 @@ +/* + * Licensed to the Apache Softwar

[GitHub] [inlong] healchow commented on a diff in pull request #5625: [INLONG-5621][SDK] Support multi-topic pulsar fetcher

healchow commented on code in PR #5625: URL: https://github.com/apache/inlong/pull/5625#discussion_r953292750 ## inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/fetcher/pulsar/PulsarMultiTopicsFetcher.java: ## @@ -0,0 +1,432 @@ +/* + * Licensed to the Apache Softwar

[GitHub] [inlong] EMsnap commented on a diff in pull request #5659: [INLONG-5623][SDK] Support kafka multi topics fetcher

EMsnap commented on code in PR #5659: URL: https://github.com/apache/inlong/pull/5659#discussion_r953292984 ## inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/SortClientConfig.java: ## @@ -367,6 +376,8 @@ public void setParameters(Map sortSdkParams) {

[GitHub] [inlong] healchow commented on a diff in pull request #5625: [INLONG-5621][SDK] Support multi-topic pulsar fetcher

healchow commented on code in PR #5625: URL: https://github.com/apache/inlong/pull/5625#discussion_r953293099 ## inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/fetcher/pulsar/PulsarMultiTopicsFetcher.java: ## @@ -0,0 +1,432 @@ +/* + * Licensed to the Apache Softwar

[GitHub] [inlong] healchow commented on a diff in pull request #5625: [INLONG-5621][SDK] Support multi-topic pulsar fetcher

healchow commented on code in PR #5625: URL: https://github.com/apache/inlong/pull/5625#discussion_r953294031 ## inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/fetcher/pulsar/PulsarMultiTopicsFetcher.java: ## @@ -0,0 +1,432 @@ +/* + * Licensed to the Apache Softwar

[GitHub] [inlong] healchow commented on a diff in pull request #5625: [INLONG-5621][SDK] Support multi-topic pulsar fetcher

healchow commented on code in PR #5625: URL: https://github.com/apache/inlong/pull/5625#discussion_r953294247 ## inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/fetcher/pulsar/PulsarMultiTopicsFetcher.java: ## @@ -0,0 +1,432 @@ +/* + * Licensed to the Apache Softwar

[GitHub] [inlong] healchow commented on a diff in pull request #5625: [INLONG-5621][SDK] Support multi-topic pulsar fetcher

healchow commented on code in PR #5625: URL: https://github.com/apache/inlong/pull/5625#discussion_r953295115 ## inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/fetcher/pulsar/PulsarMultiTopicsFetcher.java: ## @@ -0,0 +1,432 @@ +/* + * Licensed to the Apache Softwar

[GitHub] [inlong] EMsnap merged pull request #5664: [INLONG-5663][Agent] To update data structure for k8s log

EMsnap merged PR #5664: URL: https://github.com/apache/inlong/pull/5664 -- 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: commits-unsubscr...@inlong.apach

[inlong] branch master updated: [INLONG-5663][Agent] To update data structure for k8s log (#5664)

This is an automated email from the ASF dual-hosted git repository. zirui pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/inlong.git The following commit(s) were added to refs/heads/master by this push: new f150ddbeb [INLONG-5663][Agent] To update data str

[GitHub] [inlong] healchow commented on a diff in pull request #5659: [INLONG-5623][SDK] Support kafka multi topics fetcher

healchow commented on code in PR #5659: URL: https://github.com/apache/inlong/pull/5659#discussion_r953296680 ## inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/fetcher/kafka/KafkaMultiTopicsFetcher.java: ## @@ -0,0 +1,388 @@ +/* + * Licensed to the Apache Software

[GitHub] [inlong] EMsnap merged pull request #5656: [INLONG-5655][Release] Change version from 1.3.0-SNAPSHOT to 1.3.0

EMsnap merged PR #5656: URL: https://github.com/apache/inlong/pull/5656 -- 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: commits-unsubscr...@inlong.apach

[inlong] branch release-1.3.0 updated (38dfe734f -> 4e672def5)

This is an automated email from the ASF dual-hosted git repository. zirui pushed a change to branch release-1.3.0 in repository https://gitbox.apache.org/repos/asf/inlong.git from 38dfe734f [INLONG-5650][Manager] Remove the non-null check of the Pulsar adminURL (#5651) add 4e672def5 [I

[GitHub] [inlong] EMsnap commented on issue #5655: [Release] Change version from 1.3.0-SNAPSHOT to 1.3.0

EMsnap commented on issue #5655: URL: https://github.com/apache/inlong/issues/5655#issuecomment-1225148436 see https://github.com/apache/inlong/pull/5656 -- 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

[GitHub] [inlong] EMsnap commented on a diff in pull request #5661: [INLONG-5657][Release] Change the tag of Docker images to 1.3.0

EMsnap commented on code in PR #5661: URL: https://github.com/apache/inlong/pull/5661#discussion_r953313789 ## inlong-agent/agent-common/pom.xml: ## @@ -23,7 +23,7 @@ org.apache.inlong inlong-agent -1.3.0-SNAPSHOT Review Comment: see https://g

[inlong] branch release-1.3.0 updated: [INLONG-5658][DataProxy] Fix incorrect docker script (#5660)

This is an automated email from the ASF dual-hosted git repository. healchow pushed a commit to branch release-1.3.0 in repository https://gitbox.apache.org/repos/asf/inlong.git The following commit(s) were added to refs/heads/release-1.3.0 by this push: new 13c193786 [INLONG-5658][DataProx

[GitHub] [inlong] pocozh opened a new pull request, #5668: [INLONG-5667][SDK] Change key value of groupId and streamId while wrapping message

pocozh opened a new pull request, #5668: URL: https://github.com/apache/inlong/pull/5668 ### Prepare a Pull Request *(Change the title refer to the following example)* - [INLONG-5667][SDK] Change key value of groupId and streamId while wrapping message *(The following *XYZ*

[inlong] branch release-1.3.0 updated (13c193786 -> f1346a657)

This is an automated email from the ASF dual-hosted git repository. zirui pushed a change to branch release-1.3.0 in repository https://gitbox.apache.org/repos/asf/inlong.git from 13c193786 [INLONG-5658][DataProxy] Fix incorrect docker script (#5660) new 9b8a0c335 [INLONG-5648][Dashboar

[inlong] 02/03: [INLONG-5652][Docker] Fix push aarch64 images script (#5653)

This is an automated email from the ASF dual-hosted git repository. zirui pushed a commit to branch release-1.3.0 in repository https://gitbox.apache.org/repos/asf/inlong.git commit 5c6f52ffdb050436d8a9eda2584f145e4041bbd9 Author: Lucas <100204617+lucaspeng12...@users.noreply.github.com> AuthorDa

[inlong] 03/03: [INLONG-5663][Agent] To update data structure for k8s log (#5664)

This is an automated email from the ASF dual-hosted git repository. zirui pushed a commit to branch release-1.3.0 in repository https://gitbox.apache.org/repos/asf/inlong.git commit f1346a65726fdf38d3edde41193d09ee2b39a130 Author: ganfengtan AuthorDate: Wed Aug 24 11:37:23 2022 +0800 [INLON

[inlong] 01/03: [INLONG-5648][Dashboard] Optimize the create logic, support specifying specific types (#5649)

This is an automated email from the ASF dual-hosted git repository. zirui pushed a commit to branch release-1.3.0 in repository https://gitbox.apache.org/repos/asf/inlong.git commit 9b8a0c3352ce53701568d4a433f87d39b79996f7 Author: Daniel AuthorDate: Wed Aug 24 09:49:36 2022 +0800 [INLONG-56

[GitHub] [inlong] vernedeng commented on a diff in pull request #5625: [INLONG-5621][SDK] Support multi-topic pulsar fetcher

vernedeng commented on code in PR #5625: URL: https://github.com/apache/inlong/pull/5625#discussion_r953408862 ## inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/fetcher/pulsar/PulsarMultiTopicsFetcher.java: ## @@ -0,0 +1,432 @@ +/* + * Licensed to the Apache Softwa

[GitHub] [inlong] vernedeng commented on a diff in pull request #5625: [INLONG-5621][SDK] Support multi-topic pulsar fetcher

vernedeng commented on code in PR #5625: URL: https://github.com/apache/inlong/pull/5625#discussion_r953409242 ## inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/fetcher/pulsar/PulsarMultiTopicsFetcher.java: ## @@ -0,0 +1,432 @@ +/* + * Licensed to the Apache Softwa

[GitHub] [inlong] vernedeng commented on a diff in pull request #5625: [INLONG-5621][SDK] Support multi-topic pulsar fetcher

vernedeng commented on code in PR #5625: URL: https://github.com/apache/inlong/pull/5625#discussion_r953411804 ## inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/fetcher/pulsar/PulsarMultiTopicsFetcher.java: ## @@ -0,0 +1,432 @@ +/* + * Licensed to the Apache Softwa

[GitHub] [inlong] vernedeng commented on a diff in pull request #5625: [INLONG-5621][SDK] Support multi-topic pulsar fetcher

vernedeng commented on code in PR #5625: URL: https://github.com/apache/inlong/pull/5625#discussion_r953412575 ## inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/fetcher/pulsar/PulsarMultiTopicsFetcher.java: ## @@ -0,0 +1,432 @@ +/* + * Licensed to the Apache Softwa