project refactoring

conduktor · Aug 28, 2018 · ff07b17 · ff07b17
1 parent b4dcac9
commit ff07b17
Show file tree

Hide file tree

Showing 11 changed files with 84 additions and 32 deletions.
diff --git a/kafka-basics/pom.xml b/kafka-basics/pom.xml
@@ -0,0 +1,32 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<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/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>kafka-beginners-course</artifactId>
+        <groupId>com.github.simplesteph</groupId>
+        <version>1.0</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>kafka-basics</artifactId>
+
+
+    <dependencies>
+        <!-- https://mvnrepository.com/artifact/org.apache.kafka/kafka-clients -->
+        <dependency>
+            <groupId>org.apache.kafka</groupId>
+            <artifactId>kafka-clients</artifactId>
+            <version>2.0.0</version>
+        </dependency>
+
+        <!-- https://mvnrepository.com/artifact/org.slf4j/slf4j-simple -->
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-simple</artifactId>
+            <version>1.7.25</version>
+        </dependency>
+
+    </dependencies>
+
+</project>
diff --git a/...lesteph/kafka/tutorial1/ConsumerDemo.java → ...in/java/kafka/tutorial1/ConsumerDemo.java b/...lesteph/kafka/tutorial1/ConsumerDemo.java → ...in/java/kafka/tutorial1/ConsumerDemo.java
@@ -1,4 +1,4 @@
-package com.github.simplesteph.kafka.tutorial1;
+package kafka.tutorial1;
 
 import org.apache.kafka.clients.consumer.ConsumerConfig;
 import org.apache.kafka.clients.consumer.ConsumerRecord;
@@ -10,7 +10,6 @@
 
 import java.time.Duration;
 import java.util.Arrays;
-import java.util.Collections;
 import java.util.Properties;
 
 public class ConsumerDemo {

diff --git a/...fka/tutorial1/ConsumerDemoAssignSeek.java → ...fka/tutorial1/ConsumerDemoAssignSeek.java b/...fka/tutorial1/ConsumerDemoAssignSeek.java → ...fka/tutorial1/ConsumerDemoAssignSeek.java
@@ -1,4 +1,4 @@
-package com.github.simplesteph.kafka.tutorial1;
+package kafka.tutorial1;
 
 import org.apache.kafka.clients.consumer.ConsumerConfig;
 import org.apache.kafka.clients.consumer.ConsumerRecord;

diff --git a/...h/kafka/tutorial1/ConsumerDemoGroups.java → ...a/kafka/tutorial1/ConsumerDemoGroups.java b/...h/kafka/tutorial1/ConsumerDemoGroups.java → ...a/kafka/tutorial1/ConsumerDemoGroups.java
@@ -1,4 +1,4 @@
-package com.github.simplesteph.kafka.tutorial1;
+package kafka.tutorial1;
 
 import org.apache.kafka.clients.consumer.ConsumerConfig;
 import org.apache.kafka.clients.consumer.ConsumerRecord;

diff --git a/...fka/tutorial1/ConsumerDemoWithThread.java → ...fka/tutorial1/ConsumerDemoWithThread.java b/...fka/tutorial1/ConsumerDemoWithThread.java → ...fka/tutorial1/ConsumerDemoWithThread.java
@@ -1,4 +1,4 @@
-package com.github.simplesteph.kafka.tutorial1;
+package kafka.tutorial1;
 
 import org.apache.kafka.clients.consumer.ConsumerConfig;
 import org.apache.kafka.clients.consumer.ConsumerRecord;

diff --git a/...lesteph/kafka/tutorial1/ProducerDemo.java → ...in/java/kafka/tutorial1/ProducerDemo.java b/...lesteph/kafka/tutorial1/ProducerDemo.java → ...in/java/kafka/tutorial1/ProducerDemo.java
@@ -1,4 +1,4 @@
-package com.github.simplesteph.kafka.tutorial1;
+package kafka.tutorial1;
 
 import org.apache.kafka.clients.producer.KafkaProducer;
 import org.apache.kafka.clients.producer.ProducerConfig;

diff --git a/...eph/kafka/tutorial1/ProducerDemoKeys.java → ...ava/kafka/tutorial1/ProducerDemoKeys.java b/...eph/kafka/tutorial1/ProducerDemoKeys.java → ...ava/kafka/tutorial1/ProducerDemoKeys.java
@@ -1,4 +1,4 @@
-package com.github.simplesteph.kafka.tutorial1;
+package kafka.tutorial1;
 
 import org.apache.kafka.clients.producer.*;
 import org.apache.kafka.common.serialization.StringSerializer;

diff --git a/...a/tutorial1/ProducerDemoWithCallback.java → ...a/tutorial1/ProducerDemoWithCallback.java b/...a/tutorial1/ProducerDemoWithCallback.java → ...a/tutorial1/ProducerDemoWithCallback.java
@@ -1,4 +1,4 @@
-package com.github.simplesteph.kafka.tutorial1;
+package kafka.tutorial1;
 
 import org.apache.kafka.clients.producer.*;
 import org.apache.kafka.common.serialization.StringSerializer;

diff --git a/kafka-producer-twitter/pom.xml b/kafka-producer-twitter/pom.xml
@@ -0,0 +1,39 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<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/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>kafka-beginners-course</artifactId>
+        <groupId>com.github.simplesteph</groupId>
+        <version>1.0</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>kafka-producer-twitter</artifactId>
+
+
+    <dependencies>
+        <!-- https://mvnrepository.com/artifact/org.apache.kafka/kafka-clients -->
+        <dependency>
+            <groupId>org.apache.kafka</groupId>
+            <artifactId>kafka-clients</artifactId>
+            <version>2.0.0</version>
+        </dependency>
+
+        <!-- https://mvnrepository.com/artifact/org.slf4j/slf4j-simple -->
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-simple</artifactId>
+            <version>1.7.25</version>
+        </dependency>
+
+        <!--twitter dependency-->
+        <dependency>
+            <groupId>com.twitter</groupId>
+            <artifactId>hbc-core</artifactId> <!-- or hbc-twitter4j -->
+            <version>2.2.0</version> <!-- or whatever the latest version is -->
+        </dependency>
+
+    </dependencies>
+
+</project>
diff --git a/...teph/kafka/tutorial2/TwitterProducer.java → ...java/kafka/tutorial2/TwitterProducer.java b/...teph/kafka/tutorial2/TwitterProducer.java → ...java/kafka/tutorial2/TwitterProducer.java
@@ -1,4 +1,4 @@
-package com.github.simplesteph.kafka.tutorial2;
+package kafka.tutorial2;
 
 import com.google.common.collect.Lists;
 import com.twitter.hbc.ClientBuilder;

diff --git a/pom.xml b/pom.xml
@@ -6,6 +6,7 @@
 
     <groupId>com.github.simplesteph</groupId>
     <artifactId>kafka-beginners-course</artifactId>
+    <packaging>pom</packaging>
     <version>1.0</version>
     <build>
         <plugins>
@@ -19,30 +20,11 @@
             </plugin>
         </plugins>
     </build>
+    <modules>
+        <module>kafka-basics</module>
+        <module>kafka-producer-twitter</module>
+    </modules>
 
-    <dependencies>
-        <!-- https://mvnrepository.com/artifact/org.apache.kafka/kafka-clients -->
-        <dependency>
-            <groupId>org.apache.kafka</groupId>
-            <artifactId>kafka-clients</artifactId>
-            <version>2.0.0</version>
-        </dependency>
-
-        <!-- https://mvnrepository.com/artifact/org.slf4j/slf4j-simple -->
-        <dependency>
-            <groupId>org.slf4j</groupId>
-            <artifactId>slf4j-simple</artifactId>
-            <version>1.7.25</version>
-        </dependency>
-
-        <!--twitter dependency-->
-        <dependency>
-            <groupId>com.twitter</groupId>
-            <artifactId>hbc-core</artifactId> <!-- or hbc-twitter4j -->
-            <version>2.2.0</version> <!-- or whatever the latest version is -->
-        </dependency>
-
-    </dependencies>
 
 
 </project>