Move consumers to core module

Author: Pavel Derendyaev

build.gradle

@@ -13,41 +13,42 @@ buildscript {
     }
 }
 
-apply plugin: 'java'
 apply plugin: 'application'
 apply plugin: 'com.bmuschko.docker-remote-api'
 apply plugin: 'com.github.johnrengelman.shadow'
 
-group = 'com.github.dddpaul.kafka'
-version = '0.0.1-SNAPSHOT'
-mainClassName = 'com.github.dddpaul.kafka.rewind.Application'
-sourceCompatibility = 1.9
 
-ext {
-    dockerPrefix = "dddpaul"
-}
+allprojects {
+    group = 'com.github.dddpaul.kafka'
+    version = '0.0.1-SNAPSHOT'
+    mainClassName = 'com.github.dddpaul.kafka.rewind.Application'
+    sourceCompatibility = 1.9
+
+    apply plugin: 'java'
+
+    ext {
+        dockerPrefix = "dddpaul"
+    }
+
+    repositories {
+        jcenter()
+        mavenCentral()
+    }
 
-repositories {
-    jcenter()
-    mavenCentral()
+    task wrapper(type: Wrapper) {
+        gradleVersion = '4.2.1'
+        distributionUrl = 'https://services.gradle.org/distributions/gradle-4.2.1-all.zip'
+    }
 }
 
 dependencies {
-    compile 'info.picocli:picocli:2.2.0'
-    compile 'io.vavr:vavr:0.9.2'
-    compile 'org.slf4j:slf4j-simple:1.7.25'
-    compile 'org.apache.kafka:kafka-clients:0.11.0.2'
+    compile project(':core')
     testCompile 'com.github.charithe:kafka-junit:4.1.0'
     testCompile 'org.assertj:assertj-core:3.8.0'
     testCompile 'org.apiguardian:apiguardian-api:1.0.0'
     testCompile 'org.apache.commons:commons-configuration2:2.2'
 }
 
-task wrapper(type: Wrapper) {
-    gradleVersion = '4.1'
-    distributionUrl = 'https://services.gradle.org/distributions/gradle-4.2.1-all.zip'
-}
-
 task createDockerfile(type: Dockerfile) {
     dependsOn shadowJar
     destFile = project.file("${project.buildDir}/Dockerfile")

core/build.gradle

@@ -0,0 +1,6 @@
+dependencies {
+    compile 'info.picocli:picocli:2.2.0'
+    compile 'io.vavr:vavr:0.9.2'
+    compile 'org.slf4j:slf4j-simple:1.7.25'
+    compile 'org.apache.kafka:kafka-clients:0.11.0.2'
+}

src/main/java/com/github/dddpaul/kafka/rewind/Seeker.java renamed to core/src/main/java/com/github/dddpaul/kafka/rewind/consumers/Seeker.java

@@ -1,4 +1,4 @@
-package com.github.dddpaul.kafka.rewind;
+package com.github.dddpaul.kafka.rewind.consumers;
 
 import org.apache.kafka.clients.consumer.KafkaConsumer;
 import org.apache.kafka.clients.consumer.OffsetAndTimestamp;

src/main/java/com/github/dddpaul/kafka/rewind/SimpleConsumer.java renamed to core/src/main/java/com/github/dddpaul/kafka/rewind/consumers/SimpleConsumer.java

@@ -1,4 +1,4 @@
-package com.github.dddpaul.kafka.rewind;
+package com.github.dddpaul.kafka.rewind.consumers;
 
 import org.apache.kafka.clients.consumer.ConsumerRecords;
 import org.apache.kafka.clients.consumer.KafkaConsumer;

settings.gradle

@@ -0,0 +1,2 @@
+include 'core'
+

src/main/java/com/github/dddpaul/kafka/rewind/Application.java

@@ -1,5 +1,7 @@
 package com.github.dddpaul.kafka.rewind;
 
+import com.github.dddpaul.kafka.rewind.consumers.Seeker;
+import com.github.dddpaul.kafka.rewind.consumers.SimpleConsumer;
 import io.vavr.control.Try;
 import org.apache.kafka.clients.consumer.KafkaConsumer;
 import org.slf4j.Logger;