Re: [PR] KAFKA-14752: Kafka examples improvements - processor changes [kafka]

2024-03-20 Thread via GitHub
fvaleri commented on code in PR #13516: URL: https://github.com/apache/kafka/pull/13516#discussion_r1531939832 ## examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java: ## @@ -81,111 +88,115 @@ public ExactlyOnceMessageProcessor(final String inputTopic,

Re: [PR] KAFKA-14752: Kafka examples improvements - processor changes [kafka]

2024-03-19 Thread via GitHub
gaoran10 commented on code in PR #13516: URL: https://github.com/apache/kafka/pull/13516#discussion_r1531455051 ## examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java: ## @@ -81,111 +88,115 @@ public ExactlyOnceMessageProcessor(final String inputTopic,

Re: [PR] KAFKA-14752: Kafka examples improvements - processor changes [kafka]

2024-03-19 Thread via GitHub
fvaleri commented on code in PR #13516: URL: https://github.com/apache/kafka/pull/13516#discussion_r1530075375 ## examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java: ## @@ -81,111 +88,115 @@ public ExactlyOnceMessageProcessor(final String inputTopic,

Re: [PR] KAFKA-14752: Kafka examples improvements - processor changes [kafka]

2024-03-19 Thread via GitHub
fvaleri commented on code in PR #13516: URL: https://github.com/apache/kafka/pull/13516#discussion_r1530075375 ## examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java: ## @@ -81,111 +88,115 @@ public ExactlyOnceMessageProcessor(final String inputTopic,

Re: [PR] KAFKA-14752: Kafka examples improvements - processor changes [kafka]

2024-03-18 Thread via GitHub
gaoran10 commented on code in PR #13516: URL: https://github.com/apache/kafka/pull/13516#discussion_r1529639335 ## examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java: ## @@ -81,111 +88,115 @@ public ExactlyOnceMessageProcessor(final String inputTopic,

Re: [PR] KAFKA-14752: Kafka examples improvements - processor changes [kafka]

2024-03-18 Thread via GitHub
gaoran10 commented on code in PR #13516: URL: https://github.com/apache/kafka/pull/13516#discussion_r1529639335 ## examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java: ## @@ -81,111 +88,115 @@ public ExactlyOnceMessageProcessor(final String inputTopic,

Re: [PR] KAFKA-14752: Kafka examples improvements - processor changes [kafka]

2024-03-18 Thread via GitHub
fvaleri commented on code in PR #13516: URL: https://github.com/apache/kafka/pull/13516#discussion_r1528843407 ## examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java: ## @@ -81,111 +88,115 @@ public ExactlyOnceMessageProcessor(final String inputTopic,

Re: [PR] KAFKA-14752: Kafka examples improvements - processor changes [kafka]

2024-03-18 Thread via GitHub
gaoran10 commented on code in PR #13516: URL: https://github.com/apache/kafka/pull/13516#discussion_r1528650747 ## examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java: ## @@ -81,111 +88,115 @@ public ExactlyOnceMessageProcessor(final String inputTopic,

Re: [PR] KAFKA-14752: Kafka examples improvements - processor changes [kafka]

2024-03-18 Thread via GitHub
gaoran10 commented on code in PR #13516: URL: https://github.com/apache/kafka/pull/13516#discussion_r1528650747 ## examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java: ## @@ -81,111 +88,115 @@ public ExactlyOnceMessageProcessor(final String inputTopic,

Re: [PR] KAFKA-14752: Kafka examples improvements - processor changes [kafka]

2024-03-18 Thread via GitHub
gaoran10 commented on code in PR #13516: URL: https://github.com/apache/kafka/pull/13516#discussion_r1528650747 ## examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java: ## @@ -81,111 +88,115 @@ public ExactlyOnceMessageProcessor(final String inputTopic,