Re: [PR] [improve] update config default value and add combine flush mode [doris-kafka-connector]

2025-05-08 Thread via GitHub
chuang-wang-pre commented on code in PR #73: URL: https://github.com/apache/doris-kafka-connector/pull/73#discussion_r2080993360 ## src/main/java/org/apache/doris/kafka/connector/service/DorisCombinedSinkService.java: ## @@ -0,0 +1,143 @@ +/* + * Licensed to the Apache Software

Re: [PR] [improve] update config default value and add combine flush mode [doris-kafka-connector]

2025-05-08 Thread via GitHub
JNSimba commented on code in PR #73: URL: https://github.com/apache/doris-kafka-connector/pull/73#discussion_r2080824130 ## src/main/java/org/apache/doris/kafka/connector/service/DorisCombinedSinkService.java: ## @@ -0,0 +1,143 @@ +/* + * Licensed to the Apache Software Foundat

Re: [PR] [improve] update config default value and add combine flush mode [doris-kafka-connector]

2025-05-08 Thread via GitHub
JNSimba commented on code in PR #73: URL: https://github.com/apache/doris-kafka-connector/pull/73#discussion_r2080766838 ## src/main/java/org/apache/doris/kafka/connector/service/DorisCombinedSinkService.java: ## @@ -0,0 +1,143 @@ +/* + * Licensed to the Apache Software Foundat

Re: [PR] [improve] update config default value and add combine flush mode [doris-kafka-connector]

2025-05-08 Thread via GitHub
DongLiang-0 commented on code in PR #73: URL: https://github.com/apache/doris-kafka-connector/pull/73#discussion_r2080756707 ## src/main/java/org/apache/doris/kafka/connector/service/DorisCombinedSinkService.java: ## @@ -0,0 +1,143 @@ +/* + * Licensed to the Apache Software Fou

Re: [PR] [improve] update config default value and add combine flush mode [doris-kafka-connector]

2025-05-08 Thread via GitHub
JNSimba commented on code in PR #73: URL: https://github.com/apache/doris-kafka-connector/pull/73#discussion_r2079706137 ## src/main/java/org/apache/doris/kafka/connector/service/DorisCombinedSinkService.java: ## @@ -0,0 +1,276 @@ +/* + * Licensed to the Apache Software Foundat

Re: [PR] [improve] update config default value and add combine flush mode [doris-kafka-connector]

2025-05-08 Thread via GitHub
DongLiang-0 commented on code in PR #73: URL: https://github.com/apache/doris-kafka-connector/pull/73#discussion_r2079663191 ## src/main/java/org/apache/doris/kafka/connector/service/DorisCombinedSinkService.java: ## @@ -0,0 +1,276 @@ +/* + * Licensed to the Apache Software Fou