fix(kafka): remove global consumer and autoclose it

camunda · Jan 23, 2025 · dc47039 · dc47039
1 parent 11c0f51
commit dc47039
Showing 1 changed file with 0 additions and 13 deletions.
diff --git a/...ectors/kafka/src/main/java/io/camunda/connector/kafka/inbound/KafkaConnectorConsumer.java b/...ectors/kafka/src/main/java/io/camunda/connector/kafka/inbound/KafkaConnectorConsumer.java
@@ -96,19 +96,6 @@ public void startConsumer() {
             return null;
           } catch (Exception ex) {
             LOG.error("Consumer loop failure, retry pending: {}", ex.getMessage(), ex);
-<<<<<<< Updated upstream
-            try {
-              if (consumer != null) {
-                consumer.close();
-              }
-            } catch (Exception e) {
-              LOG.error(
-                  "Failed to close consumer before retrying, reason: {}. "
-                      + "This error will be ignored. If the consumer is still running, it will be disconnected after max.poll.interval.ms.",
-                  e.getMessage());
-            }
-=======
->>>>>>> Stashed changes
             throw ex;
           }
         };