Update kafka connector doc testing against latest kafka servers Project: http://git-wip-us.apache.org/repos/asf/incubator-edgent/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-edgent/commit/c4ac498c Tree: http://git-wip-us.apache.org/repos/asf/incubator-edgent/tree/c4ac498c Diff: http://git-wip-us.apache.org/repos/asf/incubator-edgent/diff/c4ac498c
Branch: refs/heads/master Commit: c4ac498cbd19fb44c4d6c1e9ad8dd662dc74ec7f Parents: f5b10c5 Author: Dale LaBossiere <[email protected]> Authored: Thu Nov 17 18:09:45 2016 -0500 Committer: Dale LaBossiere <[email protected]> Committed: Thu Nov 17 18:09:45 2016 -0500 ---------------------------------------------------------------------- .../org/apache/edgent/connectors/kafka/KafkaConsumer.java | 7 +++---- .../org/apache/edgent/connectors/kafka/KafkaProducer.java | 7 +++---- .../java/org/apache/edgent/connectors/kafka/package-info.java | 2 +- 3 files changed, 7 insertions(+), 9 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-edgent/blob/c4ac498c/connectors/kafka/src/main/java/org/apache/edgent/connectors/kafka/KafkaConsumer.java ---------------------------------------------------------------------- diff --git a/connectors/kafka/src/main/java/org/apache/edgent/connectors/kafka/KafkaConsumer.java b/connectors/kafka/src/main/java/org/apache/edgent/connectors/kafka/KafkaConsumer.java index 546a212..fa6314a 100644 --- a/connectors/kafka/src/main/java/org/apache/edgent/connectors/kafka/KafkaConsumer.java +++ b/connectors/kafka/src/main/java/org/apache/edgent/connectors/kafka/KafkaConsumer.java @@ -20,20 +20,19 @@ package org.apache.edgent.connectors.kafka; import java.util.Map; +import org.apache.edgent.connectors.kafka.runtime.KafkaConsumerConnector; +import org.apache.edgent.connectors.kafka.runtime.KafkaSubscriber; import org.apache.edgent.function.Function; import org.apache.edgent.function.Supplier; import org.apache.edgent.topology.TStream; import org.apache.edgent.topology.Topology; -import org.apache.edgent.connectors.kafka.runtime.KafkaConsumerConnector; -import org.apache.edgent.connectors.kafka.runtime.KafkaSubscriber; - /** * {@code KafkaConsumer} is a connector for creating a stream of tuples * by subscribing to Apache Kafka messaging system topics. * <p> * The connector uses and includes components from the Kafka 0.8.2.2 release. - * It has been successfully tested against a kafka_2.11-0.9.0.0 server as well. + * It has been successfully tested against kafka_2.11-0.10.1.0 and kafka_2.11-0.9.0.0 server as well. * For more information about Kafka see * <a href="http://kafka.apache.org";>http://kafka.apache.org</a> * <p> http://git-wip-us.apache.org/repos/asf/incubator-edgent/blob/c4ac498c/connectors/kafka/src/main/java/org/apache/edgent/connectors/kafka/KafkaProducer.java ---------------------------------------------------------------------- diff --git a/connectors/kafka/src/main/java/org/apache/edgent/connectors/kafka/KafkaProducer.java b/connectors/kafka/src/main/java/org/apache/edgent/connectors/kafka/KafkaProducer.java index 103d61a..9f5c265 100644 --- a/connectors/kafka/src/main/java/org/apache/edgent/connectors/kafka/KafkaProducer.java +++ b/connectors/kafka/src/main/java/org/apache/edgent/connectors/kafka/KafkaProducer.java @@ -21,21 +21,20 @@ package org.apache.edgent.connectors.kafka; import java.nio.charset.StandardCharsets; import java.util.Map; +import org.apache.edgent.connectors.kafka.runtime.KafkaProducerConnector; +import org.apache.edgent.connectors.kafka.runtime.KafkaPublisher; import org.apache.edgent.function.Function; import org.apache.edgent.function.Supplier; import org.apache.edgent.topology.TSink; import org.apache.edgent.topology.TStream; import org.apache.edgent.topology.Topology; -import org.apache.edgent.connectors.kafka.runtime.KafkaProducerConnector; -import org.apache.edgent.connectors.kafka.runtime.KafkaPublisher; - /** * {@code KafkaProducer} is a connector for publishing a stream of tuples * to Apache Kafka messaging system topics. * <p> * The connector uses and includes components from the Kafka 0.8.2.2 release. - * It has been successfully tested against a kafka_2.11-0.9.0.0 server as well. + * It has been successfully tested against kafka_2.11-0.10.1.0 and kafka_2.11-0.9.0.0 server as well. * For more information about Kafka see * <a href="http://kafka.apache.org";>http://kafka.apache.org</a> * <p> http://git-wip-us.apache.org/repos/asf/incubator-edgent/blob/c4ac498c/connectors/kafka/src/main/java/org/apache/edgent/connectors/kafka/package-info.java ---------------------------------------------------------------------- diff --git a/connectors/kafka/src/main/java/org/apache/edgent/connectors/kafka/package-info.java b/connectors/kafka/src/main/java/org/apache/edgent/connectors/kafka/package-info.java index dd1689b..3e27717 100644 --- a/connectors/kafka/src/main/java/org/apache/edgent/connectors/kafka/package-info.java +++ b/connectors/kafka/src/main/java/org/apache/edgent/connectors/kafka/package-info.java @@ -20,7 +20,7 @@ under the License. * Apache Kafka enterprise messing hub stream connector. * <p> * The connector uses and includes components from the Kafka 0.8.2.2 release. - * It has been successfully tested against a kafka_2.11-0.9.0.0 server as well. + * It has been successfully tested against kafka_2.11-0.10.1.0 and kafka_2.11-0.9.0.0 server as well. * <p> * Stream tuples may be published to Kafka broker topics * and created by subscribing to broker topics.
