This is an automated email from the ASF dual-hosted git repository. orpiske pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit 5cb623a39a9873b46dcbaa0f2e4752f89490ff4e Author: Otavio Rodolfo Piske <angusyo...@gmail.com> AuthorDate: Thu Apr 11 13:47:04 2024 +0200 CAMEL-20758: remove commented code --- .../java/org/apache/camel/component/kafka/KafkaFetchRecords.java | 6 ------ 1 file changed, 6 deletions(-) diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java index 87d2061fcf1..a614f222417 100644 --- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java +++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java @@ -311,12 +311,6 @@ public class KafkaFetchRecords implements Runnable { if (LOG.isInfoEnabled()) { LOG.info("Subscribing {} to {}", threadId, getPrintableTopic()); } - // - // if (topicPattern != null) { - // consumer.subscribe(topicPattern, listener); - // } else { - // consumer.subscribe(Arrays.asList(topicName.split(",")), listener); - // } } protected void startPolling() {