Repository: camel Updated Branches: refs/heads/camel-2.17.x 5f69d6267 -> a2665ae8b
Camel-Kafka: Camel 2.17.x is still Java 7 so we need to implement the method remove in our Iterator of ProducerRecord Objects Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/a2665ae8 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/a2665ae8 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/a2665ae8 Branch: refs/heads/camel-2.17.x Commit: a2665ae8b6bdd2eb1560c4a08fff081839b474a4 Parents: 5f69d62 Author: Andrea Cosentino <anco...@gmail.com> Authored: Fri Jun 17 14:32:24 2016 +0200 Committer: Andrea Cosentino <anco...@gmail.com> Committed: Fri Jun 17 14:32:24 2016 +0200 ---------------------------------------------------------------------- .../java/org/apache/camel/component/kafka/KafkaProducer.java | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/a2665ae8/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaProducer.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaProducer.java index e2f25fb..37cc920 100644 --- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaProducer.java +++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaProducer.java @@ -141,6 +141,11 @@ public class KafkaProducer extends DefaultAsyncProducer { } return new ProducerRecord(msgTopic, msgList.next()); } + + @Override + public void remove() { + msgList.remove(); + } }; } ProducerRecord record;
