diff --git a/build.gradle b/build.gradle
index 100230e..cbe32ed 100644
--- 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
index e1b4f9d..b5a044c 100644
--- a/gradle.properties
+++ b/gradle.properties
@@ -1,3 +1,4 @@
-version=1.0.1
-ossrhUsername=me
-ossrhPassword=you
\ No newline at end of file
+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
index 9653eb7..9b74ff5 100644
--- 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 {