You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2018/08/16 13:31:13 UTC
[camel] branch master updated: Polished
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new 08eb993 Polished
08eb993 is described below
commit 08eb993e1b8fa05beec5a7e3f0a26ce2c1c01dba
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Thu Aug 16 15:30:58 2018 +0200
Polished
---
.../src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java | 1 -
1 file changed, 1 deletion(-)
diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java
index df3b4b5..b18888c 100644
--- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java
+++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java
@@ -316,7 +316,6 @@ public class KafkaConsumer extends DefaultConsumer {
KafkaManualCommit manual = endpoint.getComponent().getKafkaManualCommitFactory().newInstance(exchange, consumer, topicName, threadId,
offsetRepository, partition, record.offset());
exchange.getIn().setHeader(KafkaConstants.MANUAL_COMMIT, manual);
-
}
try {