You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@edgent.apache.org by dl...@apache.org on 2016/12/14 19:24:30 UTC
[40/50] [abbrv] incubator-edgent git commit: Update kafka connector
doc testing against latest kafka servers
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 <dl...@us.ibm.com>
Authored: Thu Nov 17 18:09:45 2016 -0500
Committer: Dale LaBossiere <dl...@us.ibm.com>
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.