Re: [PR] [INLONG-9804][Agent] Add Pulsar source for Agent [inlong]

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

Re: [PR] [INLONG-9804][Agent] Add Pulsar source for Agent [inlong]

haifxu commented on code in PR #9805: URL: https://github.com/apache/inlong/pull/9805#discussion_r1522825927 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/PulsarSource.java: ## @@ -0,0 +1,312 @@ +/* + * Licensed to the Apache Software Foundat

Re: [PR] [INLONG-9804][Agent] Add Pulsar source for Agent [inlong]

haifxu commented on code in PR #9805: URL: https://github.com/apache/inlong/pull/9805#discussion_r1522823592 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/PulsarSource.java: ## @@ -0,0 +1,312 @@ +/* + * Licensed to the Apache Software Foundat

Re: [PR] [INLONG-9804][Agent] Add Pulsar source for Agent [inlong]

aloyszhang commented on code in PR #9805: URL: https://github.com/apache/inlong/pull/9805#discussion_r1522755754 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/PulsarSource.java: ## @@ -0,0 +1,312 @@ +/* + * Licensed to the Apache Software Fou

Re: [PR] [INLONG-9804][Agent] Add Pulsar source for Agent [inlong]

aloyszhang commented on code in PR #9805: URL: https://github.com/apache/inlong/pull/9805#discussion_r1522755754 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/PulsarSource.java: ## @@ -0,0 +1,312 @@ +/* + * Licensed to the Apache Software Fou

Re: [PR] [INLONG-9804][Agent] Add Pulsar source for Agent [inlong]

haifxu commented on code in PR #9805: URL: https://github.com/apache/inlong/pull/9805#discussion_r1522684119 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/PulsarSource.java: ## @@ -0,0 +1,312 @@ +/* + * Licensed to the Apache Software Foundat

Re: [PR] [INLONG-9804][Agent] Add Pulsar source for Agent [inlong]

haifxu commented on code in PR #9805: URL: https://github.com/apache/inlong/pull/9805#discussion_r1522641808 ## inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/TaskConstants.java: ## @@ -117,6 +117,14 @@ public class TaskConstants extends CommonConstants

Re: [PR] [INLONG-9804][Agent] Add Pulsar source for Agent [inlong]

aloyszhang commented on code in PR #9805: URL: https://github.com/apache/inlong/pull/9805#discussion_r1522633837 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/PulsarSource.java: ## @@ -0,0 +1,312 @@ +/* + * Licensed to the Apache Software Fou

Re: [PR] [INLONG-9804][Agent] Add Pulsar Source for Agent [inlong]

aloyszhang commented on code in PR #9805: URL: https://github.com/apache/inlong/pull/9805#discussion_r1522613659 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/PulsarSource.java: ## @@ -0,0 +1,312 @@ +/* + * Licensed to the Apache Software Fou

Re: [PR] [INLONG-9804][Agent] Add Pulsar Source for Agent [inlong]

aloyszhang commented on code in PR #9805: URL: https://github.com/apache/inlong/pull/9805#discussion_r1522610517 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/PulsarSource.java: ## @@ -0,0 +1,312 @@ +/* + * Licensed to the Apache Software Fou

Re: [PR] [INLONG-9804][Agent] Add Pulsar Source for Agent [inlong]

aloyszhang commented on code in PR #9805: URL: https://github.com/apache/inlong/pull/9805#discussion_r1522590531 ## inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/TaskConstants.java: ## @@ -117,6 +117,14 @@ public class TaskConstants extends CommonConst

Re: [PR] [INLONG-9804][Agent] Add Pulsar Source for Agent [inlong]

aloyszhang commented on code in PR #9805: URL: https://github.com/apache/inlong/pull/9805#discussion_r1522589764 ## inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/TaskConstants.java: ## @@ -117,6 +117,14 @@ public class TaskConstants extends CommonConst

Re: [PR] [INLONG-9804][Agent] Add Pulsar Source for Agent [inlong]

aloyszhang commented on code in PR #9805: URL: https://github.com/apache/inlong/pull/9805#discussion_r1522589537 ## inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/TaskConstants.java: ## @@ -117,6 +117,14 @@ public class TaskConstants extends CommonConst

Re: [PR] [INLONG-9804][Agent] Add Pulsar Source for Agent [inlong]

dockerzhang commented on code in PR #9805: URL: https://github.com/apache/inlong/pull/9805#discussion_r1522472066 ## inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/pojo/TaskProfileDto.java: ## @@ -209,6 +213,21 @@ private static KafkaJob getKafkaJob(DataConfig

Re: [PR] [INLONG-9804][Agent] Add Pulsar Source for Agent [inlong]

haifxu commented on code in PR #9805: URL: https://github.com/apache/inlong/pull/9805#discussion_r1522401801 ## inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/TaskConstants.java: ## @@ -117,6 +117,14 @@ public class TaskConstants extends CommonConstants

Re: [PR] [INLONG-9804][Agent] Add Pulsar Source for Agent [inlong]

aloyszhang commented on code in PR #9805: URL: https://github.com/apache/inlong/pull/9805#discussion_r1522391284 ## inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/TaskConstants.java: ## @@ -117,6 +117,14 @@ public class TaskConstants extends CommonConst

Re: [PR] [INLONG-9804][Agent] Add Pulsar Source for Agent [inlong]

aloyszhang commented on code in PR #9805: URL: https://github.com/apache/inlong/pull/9805#discussion_r1522391284 ## inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/TaskConstants.java: ## @@ -117,6 +117,14 @@ public class TaskConstants extends CommonConst

[PR] [INLONG-9804][Agent] Add Pulsar Source for Agent [inlong]

haifxu opened a new pull request, #9805: URL: https://github.com/apache/inlong/pull/9805 ### Prepare a Pull Request - Fixes #9804 ### Motivation 1. Add `resetTime` in `PulsarTask`, used to reset consume. 2. Add `PulsarSource` to consume message. 3. Add `PulsarTask`