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 {

Reply via email to