Fixed review comments for pull request 1052.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/dc48fe7c Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/dc48fe7c Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/dc48fe7c Branch: refs/heads/master Commit: dc48fe7c2cdf01b7654e0faa937272b8a176969d Parents: a48c022 Author: Leo Prince <leoprince.francisxav...@target.com> Authored: Wed Jun 29 09:03:53 2016 -0500 Committer: Claus Ibsen <davscl...@apache.org> Committed: Fri Jul 1 08:45:31 2016 +0200 ---------------------------------------------------------------------- .../org/apache/camel/component/kafka/KafkaConstants.java | 2 +- .../java/org/apache/camel/component/kafka/KafkaProducer.java | 8 ++++---- 2 files changed, 5 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/dc48fe7c/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConstants.java ---------------------------------------------------------------------- diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConstants.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConstants.java index 1ae0759..2bd4c4d 100644 --- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConstants.java +++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConstants.java @@ -30,7 +30,7 @@ public final class KafkaConstants { public static final String KAFKA_DEFAULT_DESERIALIZER = "org.apache.kafka.common.serialization.StringDeserializer"; public static final String KAFKA_DEFAULT_PARTITIONER = "org.apache.kafka.clients.producer.internals.DefaultPartitioner"; public static final String PARTITIONER_RANGE_ASSIGNOR = "org.apache.kafka.clients.consumer.RangeAssignor"; - public static final String KAFKA_RECORDMETA = "kafka.RECORDMETA"; + public static final String KAFKA_RECORDMETA = "org.apache.kafka.clients.producer.RecordMetadata"; private KafkaConstants() { // Utility class http://git-wip-us.apache.org/repos/asf/camel/blob/dc48fe7c/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 da227c7..bba8d82 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 @@ -38,7 +38,7 @@ import org.apache.kafka.clients.producer.ProducerRecord; import org.apache.kafka.clients.producer.RecordMetadata; public class KafkaProducer extends DefaultAsyncProducer { - + private org.apache.kafka.clients.producer.KafkaProducer kafkaProducer; private final KafkaEndpoint endpoint; private ExecutorService workerPool; @@ -48,7 +48,7 @@ public class KafkaProducer extends DefaultAsyncProducer { super(endpoint); this.endpoint = endpoint; } - + Properties getProps() { Properties props = endpoint.getConfiguration().createProducerProperties(); endpoint.updateClassProperties(props); @@ -212,7 +212,7 @@ public class KafkaProducer extends DefaultAsyncProducer { private final Exchange exchange; private final AsyncCallback callback; private final AtomicInteger count = new AtomicInteger(1); - private final List<RecordMetadata> recordMetadatas = new Vector<>(); + private final List<RecordMetadata> recordMetadatas = new ArrayList<>(); KafkaProducerCallBack(Exchange exchange, AsyncCallback callback) { this.exchange = exchange; @@ -231,7 +231,7 @@ public class KafkaProducer extends DefaultAsyncProducer { } return false; } - + @Override public void onCompletion(RecordMetadata recordMetadata, Exception e) { if (e != null) {
