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 <claus.ib...@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 {