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() {

Reply via email to