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 <[email protected]>
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 {
