Merge pull request #1 from Landoop/feature/kafka_1.1

releasing 2.1 for Kafka 1.1
lensesio · Apr 25, 2018 · 38b0dad · 38b0dad
2 parents 09bbccd + 90a3905
commit 38b0dad
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 8 deletions.
diff --git a/build.gradle b/build.gradle
@@ -6,9 +6,9 @@ buildscript {
         }
     }
     dependencies {
-        classpath 'com.github.maiflai:gradle-scalatest:0.16'
+        classpath 'com.github.maiflai:gradle-scalatest:0.21'
         classpath 'io.codearte.gradle.nexus:gradle-nexus-staging-plugin:0.11.0'
-        classpath 'net.researchgate:gradle-release:2.4.0'
+        classpath 'net.researchgate:gradle-release:2.7.0'
     }
 }
 
@@ -32,8 +32,8 @@ allprojects {
         scalaMajorVersion = '2.11'
         scala = '2.11.11'
         scalaCheck = '1.13.5'
-        kafkaVersion = "1.0.1"
-        confluentVersion = "4.0.0"
+        kafkaVersion = "1.1.0"
+        confluentVersion = "4.1.0"
         scalaTest = '3.0.3'
         junitVersion = '4.12'
         mockitoVersion = '2.8.47'

diff --git a/gradle.properties b/gradle.properties
@@ -1,3 +1,4 @@
-version=1.0.1
-ossrhUsername=me
-ossrhPassword=you
+version=2.1
+
+ossrhUsername=you
+ossrhPassword=me
diff --git a/src/main/scala/com/landoop/kafka/testing/EmbeddedConnect.scala b/src/main/scala/com/landoop/kafka/testing/EmbeddedConnect.scala
@@ -50,7 +50,7 @@ case class EmbeddedConnect(workerConfig: Properties, connectorConfigs: List[Prop
   val configBackingStore: ConfigBackingStore = new KafkaConfigBackingStore(worker.getInternalValueConverter, config)
 
   //advertisedUrl = "" as we don't have the rest server - hopefully this will not break anything
-  herder = new DistributedHerder(config, time, worker, statusBackingStore, configBackingStore, "")
+  herder = new DistributedHerder(config, time, worker, "KafkaCluster1",statusBackingStore, configBackingStore, "")
 
   def start(): Unit = {
     try {