This is an automated email from the ASF dual-hosted git repository.
nwang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-heron.git
The following commit(s) were added to refs/heads/master by this push:
new 6ab470e Generate java kafka spout maven artifacts (#3276)
6ab470e is described below
commit 6ab470e7f18d0c9d19b9ddb2020cbadda1659966
Author: SiMing Weng <[email protected]>
AuthorDate: Wed May 29 19:17:51 2019 -0400
Generate java kafka spout maven artifacts (#3276)
* update KafkaSpout
* Revert "update KafkaSpout"
This reverts commit dc64e9ad
* simplify folder structure for Kafka Spout java codebase
generate Maven artifacts for Kafka Spout
---
.../heron-kafka-spout-parent => }/doc/README.md | 12 +--
.../src/main => sample/src}/java/BUILD | 2 +-
.../sample/HeronKafkaSpoutSampleTopology.java | 0
.../heron-kafka-spout/src/main => src}/java/BUILD | 13 ++-
.../spouts/kafka/ConsumerRecordTransformer.java | 0
.../kafka/DefaultConsumerRecordTransformer.java | 0
.../spouts/kafka/DefaultKafkaConsumerFactory.java | 0
.../spouts/kafka/DefaultTopicPatternProvider.java | 0
.../heron/spouts/kafka/KafkaConsumerFactory.java | 0
.../heron/spouts/kafka/KafkaMetricDecorator.java | 0
.../org/apache/heron/spouts/kafka/KafkaSpout.java | 0
.../heron/spouts/kafka/TopicPatternProvider.java | 0
.../heron-kafka-spout/src => }/test/java/BUILD | 2 +-
.../DefaultConsumerRecordTransformerTest.java | 0
.../kafka/DefaultKafkaConsumerFactoryTest.java | 0
.../kafka/DefaultTopicPatternProviderTest.java | 0
.../spouts/kafka/KafkaMetricDecoratorTest.java | 0
.../apache/heron/spouts/kafka/KafkaSpoutTest.java | 0
release/maven/heron-kafka-spout.template.pom | 95 ++++++++++++++++++++++
release/maven/maven-pom-version.sh | 7 ++
scripts/ci/build_maven_artifacts.sh | 7 ++
21 files changed, 129 insertions(+), 9 deletions(-)
diff --git a/contrib/spouts/kafka/java/heron-kafka-spout-parent/doc/README.md
b/contrib/spouts/kafka/doc/README.md
similarity index 67%
rename from contrib/spouts/kafka/java/heron-kafka-spout-parent/doc/README.md
rename to contrib/spouts/kafka/doc/README.md
index 6666e5c..3ef8872 100644
--- a/contrib/spouts/kafka/java/heron-kafka-spout-parent/doc/README.md
+++ b/contrib/spouts/kafka/doc/README.md
@@ -1,12 +1,12 @@
# Heron Kafka Spout
-[Kafka
Spout](../heron-kafka-spout/src/main/java/org/apache/heron/spouts/kafka/KafkaSpout.java)
enables a Heron topology to consume data from Kafka cluster as input into the
stream processing pipeline. Primarily, it is written using 2 APIs, the Heron
API and Kafka Client API.
+[Kafka Spout](../src/java/org/apache/heron/spouts/kafka/KafkaSpout.java)
enables a Heron topology to consume data from Kafka cluster as input into the
stream processing pipeline. Primarily, it is written using 2 APIs, the Heron
API and Kafka Client API.
##Configuring the underlying Kafka Consumer
-Each Kafka Spout instance creates its underlying
[Consumer](https://kafka.apache.org/21/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html)
instance via a factory interface
[KafkaConsumerFactory](../heron-kafka-spout/src/main/java/org/apache/heron/spouts/kafka/KafkaConsumerFactory.java)
that is passed in as one of the constructor arguments.
+Each Kafka Spout instance creates its underlying
[Consumer](https://kafka.apache.org/21/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html)
instance via a factory interface
[KafkaConsumerFactory](../src/java/org/apache/heron/spouts/kafka/KafkaConsumerFactory.java)
that is passed in as one of the constructor arguments.
-The simplest way is to use the provided
[DefaultKafkaConsumerFactory](../heron-kafka-spout/src/main/java/org/apache/heron/spouts/kafka/DefaultKafkaConsumerFactory.java).
It takes a `Map<String, Object>` as its only input, which should contain all
the user configured properties as instituted by
[ConsumerConfig](https://kafka.apache.org/21/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html)
+The simplest way is to use the provided
[DefaultKafkaConsumerFactory](../src/java/org/apache/heron/spouts/kafka/DefaultKafkaConsumerFactory.java).
It takes a `Map<String, Object>` as its only input, which should contain all
the user configured properties as instituted by
[ConsumerConfig](https://kafka.apache.org/21/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html)
_Note: `enable.auto.commit` is always set to false in
`DefaultKafkaConsumerFactory` because the Kafka Spout needs to manually manage
the committing of offset. Any custom implementation of `KafkaConsumerFactory`
should adhere to the same thing_
@@ -25,7 +25,7 @@ KafkaConsumerFactory<String, String> kafkaConsumerFactory =
new DefaultKafkaCons
##Subscribe to topic(s)
-The Kafka Spout instance can be configured to subscribe either a collection of
topics by specifying the list of topic name strings in `Collection<String>`, or
it can take an implementation of
[TopicPatternProvider](../heron-kafka-spout/src/main/java/org/apache/heron/spouts/kafka/TopicPatternProvider.java)
to provide a regular expression to match all the topics that it wants to
subscribe to. There is a
[DefaultTopicPatternProvider](../heron-kafka-spout/src/main/java/org/apache/heron/spout
[...]
+The Kafka Spout instance can be configured to subscribe either a collection of
topics by specifying the list of topic name strings in `Collection<String>`, or
it can take an implementation of
[TopicPatternProvider](../src/java/org/apache/heron/spouts/kafka/TopicPatternProvider.java)
to provide a regular expression to match all the topics that it wants to
subscribe to. There is a
[DefaultTopicPatternProvider](../src/java/org/apache/heron/spouts/kafka/DefaultTopicPatternProvider.java)
to c [...]
```java
//subscribe to specific named topic
@@ -37,9 +37,9 @@ new KafkaSpout<>(kafkaConsumerFactory, new
DefaultTopicPatternProvider("test-.*"
##Convert ConsumerRecord to Tuple
-The Spout delegates the conversion of each Kafka
[ConsumerRecord](https://kafka.apache.org/21/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html)
into an output tuple to the
[ConsumerRecordTransformer](../heron-kafka-spout/src/main/java/org/apache/heron/spouts/kafka/ConsumerRecordTransformer.java),
the
[DefaultConsumerRecordTransformer](../heron-kafka-spout/src/main/java/org/apache/heron/spouts/kafka/DefaultConsumerRecordTransformer.java)
is provided to simply conver [...]
+The Spout delegates the conversion of each Kafka
[ConsumerRecord](https://kafka.apache.org/21/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html)
into an output tuple to the
[ConsumerRecordTransformer](../src/java/org/apache/heron/spouts/kafka/ConsumerRecordTransformer.java),
the
[DefaultConsumerRecordTransformer](../src/java/org/apache/heron/spouts/kafka/DefaultConsumerRecordTransformer.java)
is provided to simply convert the incoming record into a tuple with 2 fiel
[...]
-User can create their own implementation of the `ConsumerRecordTransformer`
interface, and set it to the `KafkaSpout` via
[setConsumerRecordTransformer](../heron-kafka-spout/src/main/java/org/apache/heron/spouts/kafka/KafkaSpout.java)
method.
+User can create their own implementation of the `ConsumerRecordTransformer`
interface, and set it to the `KafkaSpout` via
[setConsumerRecordTransformer](../src/java/org/apache/heron/spouts/kafka/KafkaSpout.java)
method.
##Behavior in Different Topology Reliability Mode
diff --git
a/contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout-sample/src/main/java/BUILD
b/contrib/spouts/kafka/sample/src/java/BUILD
similarity index 80%
rename from
contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout-sample/src/main/java/BUILD
rename to contrib/spouts/kafka/sample/src/java/BUILD
index 04d69b0..79cc2cc 100644
---
a/contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout-sample/src/main/java/BUILD
+++ b/contrib/spouts/kafka/sample/src/java/BUILD
@@ -3,7 +3,7 @@ licenses(["notice"])
package(default_visibility = ["//visibility:public"])
heron_kafka_spout_sample_dep = [
-
"//contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/main/java:heron-kafka-spout-java",
+ "//contrib/spouts/kafka/src/java:heron-kafka-spout-java",
"//heron/api/src/java:api-java-low-level",
"//heron/common/src/java:basics-java",
"//heron/simulator/src/java:simulator-java",
diff --git
a/contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout-sample/src/main/java/org/apache/heron/spouts/kafka/sample/HeronKafkaSpoutSampleTopology.java
b/contrib/spouts/kafka/sample/src/java/org/apache/heron/spouts/kafka/sample/HeronKafkaSpoutSampleTopology.java
similarity index 100%
rename from
contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout-sample/src/main/java/org/apache/heron/spouts/kafka/sample/HeronKafkaSpoutSampleTopology.java
rename to
contrib/spouts/kafka/sample/src/java/org/apache/heron/spouts/kafka/sample/HeronKafkaSpoutSampleTopology.java
diff --git
a/contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/main/java/BUILD
b/contrib/spouts/kafka/src/java/BUILD
similarity index 61%
rename from
contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/main/java/BUILD
rename to contrib/spouts/kafka/src/java/BUILD
index efa3736..5e61a0f 100644
---
a/contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/main/java/BUILD
+++ b/contrib/spouts/kafka/src/java/BUILD
@@ -2,6 +2,16 @@ licenses(["notice"])
package(default_visibility = ["//visibility:public"])
+load("//tools/rules:build_defs.bzl", "DOCLINT_HTML_AND_SYNTAX")
+load("//tools/rules:javadoc.bzl", "java_doc")
+
+java_doc(
+ name = "heron-kafka-spout-javadoc",
+ libs = [":heron-kafka-spout-java"],
+ pkgs = ["org/apache/heron/spouts/kafka"],
+ title = "Kafka Spout Documentation",
+)
+
kafka_spout_deps = [
"//storm-compatibility/src/java:storm-compatibility-java-neverlink",
"//heron/api/src/java:api-java-low-level",
@@ -14,5 +24,6 @@ kafka_spout_deps = [
java_library(
name = "heron-kafka-spout-java",
srcs = glob(["org/apache/heron/spouts/kafka/**/*.java"]),
+ javacopts = DOCLINT_HTML_AND_SYNTAX,
deps = kafka_spout_deps,
-)
+)
\ No newline at end of file
diff --git
a/contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/main/java/org/apache/heron/spouts/kafka/ConsumerRecordTransformer.java
b/contrib/spouts/kafka/src/java/org/apache/heron/spouts/kafka/ConsumerRecordTransformer.java
similarity index 100%
rename from
contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/main/java/org/apache/heron/spouts/kafka/ConsumerRecordTransformer.java
rename to
contrib/spouts/kafka/src/java/org/apache/heron/spouts/kafka/ConsumerRecordTransformer.java
diff --git
a/contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/main/java/org/apache/heron/spouts/kafka/DefaultConsumerRecordTransformer.java
b/contrib/spouts/kafka/src/java/org/apache/heron/spouts/kafka/DefaultConsumerRecordTransformer.java
similarity index 100%
rename from
contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/main/java/org/apache/heron/spouts/kafka/DefaultConsumerRecordTransformer.java
rename to
contrib/spouts/kafka/src/java/org/apache/heron/spouts/kafka/DefaultConsumerRecordTransformer.java
diff --git
a/contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/main/java/org/apache/heron/spouts/kafka/DefaultKafkaConsumerFactory.java
b/contrib/spouts/kafka/src/java/org/apache/heron/spouts/kafka/DefaultKafkaConsumerFactory.java
similarity index 100%
rename from
contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/main/java/org/apache/heron/spouts/kafka/DefaultKafkaConsumerFactory.java
rename to
contrib/spouts/kafka/src/java/org/apache/heron/spouts/kafka/DefaultKafkaConsumerFactory.java
diff --git
a/contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/main/java/org/apache/heron/spouts/kafka/DefaultTopicPatternProvider.java
b/contrib/spouts/kafka/src/java/org/apache/heron/spouts/kafka/DefaultTopicPatternProvider.java
similarity index 100%
rename from
contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/main/java/org/apache/heron/spouts/kafka/DefaultTopicPatternProvider.java
rename to
contrib/spouts/kafka/src/java/org/apache/heron/spouts/kafka/DefaultTopicPatternProvider.java
diff --git
a/contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/main/java/org/apache/heron/spouts/kafka/KafkaConsumerFactory.java
b/contrib/spouts/kafka/src/java/org/apache/heron/spouts/kafka/KafkaConsumerFactory.java
similarity index 100%
rename from
contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/main/java/org/apache/heron/spouts/kafka/KafkaConsumerFactory.java
rename to
contrib/spouts/kafka/src/java/org/apache/heron/spouts/kafka/KafkaConsumerFactory.java
diff --git
a/contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/main/java/org/apache/heron/spouts/kafka/KafkaMetricDecorator.java
b/contrib/spouts/kafka/src/java/org/apache/heron/spouts/kafka/KafkaMetricDecorator.java
similarity index 100%
rename from
contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/main/java/org/apache/heron/spouts/kafka/KafkaMetricDecorator.java
rename to
contrib/spouts/kafka/src/java/org/apache/heron/spouts/kafka/KafkaMetricDecorator.java
diff --git
a/contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/main/java/org/apache/heron/spouts/kafka/KafkaSpout.java
b/contrib/spouts/kafka/src/java/org/apache/heron/spouts/kafka/KafkaSpout.java
similarity index 100%
rename from
contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/main/java/org/apache/heron/spouts/kafka/KafkaSpout.java
rename to
contrib/spouts/kafka/src/java/org/apache/heron/spouts/kafka/KafkaSpout.java
diff --git
a/contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/main/java/org/apache/heron/spouts/kafka/TopicPatternProvider.java
b/contrib/spouts/kafka/src/java/org/apache/heron/spouts/kafka/TopicPatternProvider.java
similarity index 100%
rename from
contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/main/java/org/apache/heron/spouts/kafka/TopicPatternProvider.java
rename to
contrib/spouts/kafka/src/java/org/apache/heron/spouts/kafka/TopicPatternProvider.java
diff --git
a/contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/test/java/BUILD
b/contrib/spouts/kafka/test/java/BUILD
similarity index 93%
rename from
contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/test/java/BUILD
rename to contrib/spouts/kafka/test/java/BUILD
index 1d9c400..f7029fa 100644
---
a/contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/test/java/BUILD
+++ b/contrib/spouts/kafka/test/java/BUILD
@@ -1,5 +1,5 @@
heron_kafka_spouts_test_dep = [
-
"//contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/main/java:heron-kafka-spout-java",
+ "//contrib/spouts/kafka/src/java:heron-kafka-spout-java",
"//heron/api/src/java:api-java-low-level",
"//heron/common/src/java:basics-java",
"//heron/common/src/java:config-java",
diff --git
a/contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/test/java/org/apache/heron/spouts/kafka/DefaultConsumerRecordTransformerTest.java
b/contrib/spouts/kafka/test/java/org/apache/heron/spouts/kafka/DefaultConsumerRecordTransformerTest.java
similarity index 100%
rename from
contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/test/java/org/apache/heron/spouts/kafka/DefaultConsumerRecordTransformerTest.java
rename to
contrib/spouts/kafka/test/java/org/apache/heron/spouts/kafka/DefaultConsumerRecordTransformerTest.java
diff --git
a/contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/test/java/org/apache/heron/spouts/kafka/DefaultKafkaConsumerFactoryTest.java
b/contrib/spouts/kafka/test/java/org/apache/heron/spouts/kafka/DefaultKafkaConsumerFactoryTest.java
similarity index 100%
rename from
contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/test/java/org/apache/heron/spouts/kafka/DefaultKafkaConsumerFactoryTest.java
rename to
contrib/spouts/kafka/test/java/org/apache/heron/spouts/kafka/DefaultKafkaConsumerFactoryTest.java
diff --git
a/contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/test/java/org/apache/heron/spouts/kafka/DefaultTopicPatternProviderTest.java
b/contrib/spouts/kafka/test/java/org/apache/heron/spouts/kafka/DefaultTopicPatternProviderTest.java
similarity index 100%
rename from
contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/test/java/org/apache/heron/spouts/kafka/DefaultTopicPatternProviderTest.java
rename to
contrib/spouts/kafka/test/java/org/apache/heron/spouts/kafka/DefaultTopicPatternProviderTest.java
diff --git
a/contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/test/java/org/apache/heron/spouts/kafka/KafkaMetricDecoratorTest.java
b/contrib/spouts/kafka/test/java/org/apache/heron/spouts/kafka/KafkaMetricDecoratorTest.java
similarity index 100%
rename from
contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/test/java/org/apache/heron/spouts/kafka/KafkaMetricDecoratorTest.java
rename to
contrib/spouts/kafka/test/java/org/apache/heron/spouts/kafka/KafkaMetricDecoratorTest.java
diff --git
a/contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/test/java/org/apache/heron/spouts/kafka/KafkaSpoutTest.java
b/contrib/spouts/kafka/test/java/org/apache/heron/spouts/kafka/KafkaSpoutTest.java
similarity index 100%
rename from
contrib/spouts/kafka/java/heron-kafka-spout-parent/heron-kafka-spout/src/test/java/org/apache/heron/spouts/kafka/KafkaSpoutTest.java
rename to
contrib/spouts/kafka/test/java/org/apache/heron/spouts/kafka/KafkaSpoutTest.java
diff --git a/release/maven/heron-kafka-spout.template.pom
b/release/maven/heron-kafka-spout.template.pom
new file mode 100644
index 0000000..5e5e2ca
--- /dev/null
+++ b/release/maven/heron-kafka-spout.template.pom
@@ -0,0 +1,95 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!-- // Licensed to the Apache Software Foundation (ASF) under one -->
+<!-- // or more contributor license agreements. See the NOTICE file -->
+<!-- // distributed with this work for additional information -->
+<!-- // regarding copyright ownership. The ASF licenses this file -->
+<!-- // to you under the Apache License, Version 2.0 (the -->
+<!-- // "License"); you may not use this file except in compliance -->
+<!-- // with the License. You may obtain a copy of the License at -->
+<!-- // -->
+<!-- // http://www.apache.org/licenses/LICENSE-2.0 -->
+<!-- // -->
+<!-- // Unless required by applicable law or agreed to in writing, -->
+<!-- // software distributed under the License is distributed on an -->
+<!-- // "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY -->
+<!-- // KIND, either express or implied. See the License for the -->
+<!-- // specific language governing permissions and limitations -->
+<!-- // under the License. -->
+
+<!--
+
+ ~ Licensed under the Apache License, Version 2.0 (the "License");
+ ~ you may not use this file except in compliance with the License.
+ ~ You may obtain a copy of the License at
+ ~
+ ~ http://www.apache.org/licenses/LICENSE-2.0
+ ~
+ ~ Unless required by applicable law or agreed to in writing, software
+ ~ distributed under the License is distributed on an "AS IS" BASIS,
+ ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ ~ See the License for the specific language governing permissions and
+ ~ limitations under the License.
+
+-->
+<project xmlns="http://maven.apache.org/POM/4.0.0";
+xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/maven-v4_0_0.xsd";>
+ <modelVersion>4.0.0</modelVersion>
+ <groupId>org.apache.heron</groupId>
+ <artifactId>ARTIFACT_ID</artifactId>
+ <version>VERSION</version>
+ <packaging>jar</packaging>
+ <name>NAME</name>
+ <description>DESCRIPTION</description>
+ <url>http://www.heronstreaming.io</url>
+ <licenses>
+ <license>
+ <name>The Apache License, Version 2.0</name>
+ <url>http://www.apache.org/licenses/LICENSE-2.0.txt</url>
+ </license>
+ </licenses>
+
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.heron</groupId>
+ <artifactId>heron-storm</artifactId>
+ <version>VERSION</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.kafka</groupId>
+ <artifactId>kafka-clients</artifactId>
+ <version>2.2.0</version>
+ </dependency>
+ </dependencies>
+
+ <mailingLists>
+ <mailingList>
+ <name>Heron user mailing list</name>
+ <subscribe>[email protected]</subscribe>
+ <unsubscribe>[email protected]</unsubscribe>
+ <post>[email protected]</post>
+ <archive>http://mail-archives.apache.org/mod_mbox/heron-user/</archive>
+ </mailingList>
+ <mailingList>
+ <name>Heron developer mailing list</name>
+ <subscribe>[email protected]</subscribe>
+ <unsubscribe>[email protected]</unsubscribe>
+ <post>[email protected]</post>
+ <archive>http://mail-archives.apache.org/mod_mbox/heron-dev/</archive>
+ </mailingList>
+ </mailingLists>
+
+ <developers>
+ <developer>
+ <name>Heron Project</name>
+ <email>[email protected]</email>
+ <organization>Apache Software Foundation</organization>
+ <organizationUrl>http://http://apache.org/</organizationUrl>
+ </developer>
+ </developers>
+ <scm>
+ <connection>scm:git:[email protected]:apache/incubator-heron.git</connection>
+
<developerConnection>scm:git:[email protected]:apache/incubator-heron.git</developerConnection>
+ <url>[email protected]:apache/incubator-heron.git</url>
+ </scm>
+</project>
diff --git a/release/maven/maven-pom-version.sh
b/release/maven/maven-pom-version.sh
index 8788f9f..a096dfc 100755
--- a/release/maven/maven-pom-version.sh
+++ b/release/maven/maven-pom-version.sh
@@ -50,3 +50,10 @@ cat ./maven/heron-with-kryo.template.pom | \
sed "s/NAME/heron-simulator/g" | \
sed "s/DESCRIPTION/Heron Simulator/g" \
>> ./heron-simulator-$1.pom
+
+cat ./maven/heron-kafka-spout.template.pom | \
+ sed "s/VERSION/$1/g" | \
+ sed "s/ARTIFACT_ID/heron-kafka-spout/g" | \
+ sed "s/NAME/heron-kafka-spout/g" | \
+ sed "s/DESCRIPTION/Heron Kafka Spout/g" \
+ >> ./heron-kafka-spout-$1.pom
\ No newline at end of file
diff --git a/scripts/ci/build_maven_artifacts.sh
b/scripts/ci/build_maven_artifacts.sh
index ccbe1ac..7a3441a 100644
--- a/scripts/ci/build_maven_artifacts.sh
+++ b/scripts/ci/build_maven_artifacts.sh
@@ -43,6 +43,7 @@ $HOME/bin/bazel build heron/api/src/java:all
$HOME/bin/bazel build heron/spi/src/java:all
$HOME/bin/bazel build heron/simulator/src/java:all
$HOME/bin/bazel build storm-compatibility/src/java:all
+$HOME/bin/bazel build contrib/spouts/kafka/src/java:all
echo "Found Version Tag $VERSION_TAG"
mkdir -p artifacts/$VERSION_TAG
@@ -62,6 +63,7 @@ mkdir -p $OUTPUT_DIR/$VERSION_TAG/heron-api
mkdir -p $OUTPUT_DIR/$VERSION_TAG/heron-spi
mkdir -p $OUTPUT_DIR/$VERSION_TAG/heron-simulator
mkdir -p $OUTPUT_DIR/$VERSION_TAG/heron-storm
+mkdir -p $OUTPUT_DIR/$VERSION_TAG/heron-kafka-spout
echo "Copy heron-api artifacts ... "
cp ./release/heron-api-$VERSION_TAG.pom $OUTPUT_DIR/$VERSION_TAG/heron-api/
@@ -87,6 +89,11 @@ cp ./bazel-bin/storm-compatibility/src/java/heron-storm.jar
./$OUTPUT_DIR/$VERSI
cp ./bazel-bin/storm-compatibility/src/java/heron-storm-javadoc.zip
./$OUTPUT_DIR/$VERSION_TAG/heron-storm/heron-storm-$VERSION_TAG-javadoc.jar
cp
./bazel-bin/storm-compatibility/src/java/libstorm-compatibility-java-src.jar
./$OUTPUT_DIR/$VERSION_TAG/heron-storm/heron-storm-$VERSION_TAG-sources.jar
+echo "Copy heron-kafka-spout artifacts ... "
+cp ./release/heron-kafka-spout-$VERSION_TAG.pom
./$OUTPUT_DIR/$VERSION_TAG/heron-kafka-spout/
+cp ./bazel-bin/contrib/spouts/kafka/src/java/libheron-kafka-spout-java.jar
./$OUTPUT_DIR/$VERSION_TAG/heron-kafka-spout/heron-kafka-spout-$VERSION_TAG.jar
+cp ./bazel-bin/contrib/spouts/kafka/src/java/heron-kafka-spout-javadoc.zip
./$OUTPUT_DIR/$VERSION_TAG/heron-kafka-spout/heron-kafka-spout-$VERSION_TAG-javadoc.jar
+cp ./bazel-bin/contrib/spouts/kafka/src/java/libheron-kafka-spout-java-src.jar
./$OUTPUT_DIR/$VERSION_TAG/heron-kafka-spout/heron-kafka-spout-$VERSION_TAG-sources.jar
echo "Compress all artifacts into a bundle file ..."
tar -czf "heron-artifacts-${VERSION_TAG}.tar.gz" $OUTPUT_DIR
