Refactoring of all gentoo classes and configs
# Please enter the commit message for your changes. Lines starting
# with '#' will be ignored, and an empty message aborts the commit.
# On branch master
# Your branch is up-to-date with 'origin/master'.
#
# Changes to be committed:
#	modified:   ../../../../../../../samza-job-package/src/main/assembly/src.xml
#	new file:   ../../../../../../../samza-job-package/src/main/config/gentoo-feed.properties
#	modified:   ../../../../../../../samza-job-package/src/main/config/wikipedia-feed.properties
#	new file:   task/GentooFeedStreamTask.java
#
diff --git a/samza-job-package/src/main/assembly/src.xml b/samza-job-package/src/main/assembly/src.xml
index 5da4bc2..0dcc513 100644
--- a/samza-job-package/src/main/assembly/src.xml
+++ b/samza-job-package/src/main/assembly/src.xml
@@ -51,6 +51,11 @@
       <outputDirectory>config</outputDirectory>
       <filtered>true</filtered>
     </file>
+    <file>
+      <source>${basedir}/src/main/config/gentoo-feed.properties</source>
+      <outputDirectory>config</outputDirectory>
+      <filtered>true</filtered>
+    </file>
   </files>
   <dependencySets>
     <dependencySet>
diff --git a/samza-job-package/src/main/config/gentoo-feed.properties b/samza-job-package/src/main/config/gentoo-feed.properties
new file mode 100644
index 0000000..ac3abe6
--- /dev/null
+++ b/samza-job-package/src/main/config/gentoo-feed.properties
@@ -0,0 +1,44 @@
+# 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.
+
+# Job
+job.factory.class=org.apache.samza.job.yarn.YarnJobFactory
+job.name=gentoo-feed
+
+# YARN
+yarn.package.path=file://${basedir}/target/${project.artifactId}-${pom.version}-dist.tar.gz
+
+# Task
+task.class=samza.examples.wikipedia.task.GentooFeedStreamTask
+task.inputs=freenode.#gentoo-chat
+
+# Serializers
+serializers.registry.json.class=org.apache.samza.serializers.JsonSerdeFactory
+
+# Wikipedia System
+systems.wikipedia.samza.factory=samza.examples.wikipedia.system.WikipediaSystemFactory
+systems.wikipedia.host=irc.freenode.org
+systems.wikipedia.port=6667
+
+# Kafka System
+systems.kafka.samza.factory=org.apache.samza.system.kafka.KafkaSystemFactory
+systems.kafka.samza.msg.serde=json
+systems.kafka.consumer.zookeeper.connect=localhost:2181/
+systems.kafka.producer.metadata.broker.list=localhost:9092
+systems.kafka.producer.producer.type=sync
+# Normally, we'd set this much higher, but we want things to look snappy in the demo.
+systems.kafka.producer.batch.num.messages=1
diff --git a/samza-job-package/src/main/config/wikipedia-feed.properties b/samza-job-package/src/main/config/wikipedia-feed.properties
index c498c16..dc7f98d 100644
--- a/samza-job-package/src/main/config/wikipedia-feed.properties
+++ b/samza-job-package/src/main/config/wikipedia-feed.properties
@@ -17,7 +17,7 @@

 # Job
 job.factory.class=org.apache.samza.job.yarn.YarnJobFactory
-job.name=wikipedia-feed
+job.name=wikipedia-feed-test1

 # YARN
 yarn.package.path=file://${basedir}/target/${project.artifactId}-${pom.version}-dist.tar.gz
@@ -41,4 +41,4 @@ systems.kafka.consumer.zookeeper.connect=localhost:2181/
 systems.kafka.producer.metadata.broker.list=localhost:9092
 systems.kafka.producer.producer.type=sync
 # Normally, we'd set this much higher, but we want things to look snappy in the demo.
-systems.kafka.producer.batch.num.messages=1
+systems.kafka.producer.batch.num.messages=10
diff --git a/samza-wikipedia/src/main/java/samza/examples/wikipedia/task/GentooFeedStreamTask.java b/samza-wikipedia/src/main/java/samza/examples/wikipedia/task/GentooFeedStreamTask.java
new file mode 100644
index 0000000..b9dd311
--- /dev/null
+++ b/samza-wikipedia/src/main/java/samza/examples/wikipedia/task/GentooFeedStreamTask.java
@@ -0,0 +1,43 @@
+/*
+ * 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.
+ */
+
+package samza.examples.wikipedia.task;
+
+import java.util.Map;
+import org.apache.samza.system.IncomingMessageEnvelope;
+import org.apache.samza.system.OutgoingMessageEnvelope;
+import org.apache.samza.system.SystemStream;
+import org.apache.samza.task.MessageCollector;
+import org.apache.samza.task.StreamTask;
+import org.apache.samza.task.TaskCoordinator;
+import samza.examples.wikipedia.system.WikipediaFeed.WikipediaFeedEvent;
+
+/**
+ * This task is very simple. All it does is take messages that it receives, and
+ * sends them to a Kafka topic called wikipedia-raw.
+ */
+public class GentooFeedStreamTask implements StreamTask {
+  private static final SystemStream OUTPUT_STREAM = new SystemStream("kafka", "gentoo-raw");
+
+  @Override
+  public void process(IncomingMessageEnvelope envelope, MessageCollector collector, TaskCoordinator coordinator) {
+    Map<String, Object> outgoingMap = WikipediaFeedEvent.toMap((WikipediaFeedEvent) envelope.getMessage());
+    collector.send(new OutgoingMessageEnvelope(OUTPUT_STREAM, outgoingMap));
+  }
+}
Formatting and minor fixes to gentoo StreamTask