Updated kafka version to 2.3.0. Added group instance id setter.

akka · Aug 13, 2019 · babe313 · babe313
1 parent 96ac7b6
commit babe313
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/build.sbt b/build.sbt
@@ -7,7 +7,7 @@ val Nightly = sys.env.get("TRAVIS_EVENT_TYPE").contains("cron")
 val Scala211 = "2.11.12"
 val Scala213 = "2.13.0"
 val akkaVersion = if (Nightly) "2.6.0-M4" else "2.5.23"
-val kafkaVersion = "2.1.1"
+val kafkaVersion = "2.3.0"
 val kafkaVersionForDocs = "21"
 val scalatestVersion = "3.0.8"
 val testcontainersVersion = "1.11.2"

diff --git a/core/src/main/scala/akka/kafka/ConsumerSettings.scala b/core/src/main/scala/akka/kafka/ConsumerSettings.scala
@@ -265,6 +265,12 @@ class ConsumerSettings[K, V] @InternalApi private[kafka] (
   def withGroupId(groupId: String): ConsumerSettings[K, V] =
     withProperty(ConsumerConfig.GROUP_ID_CONFIG, groupId)
 
+  /**
+    * An id string that marks consumer as a unique static member of the consumer group.
+    */
+  def withGroupInstanceId(groupInstanceId: String): ConsumerSettings[K, V] =
+    withProperty(ConsumerConfig.GROUP_INSTANCE_ID_CONFIG, groupInstanceId)
+
   /**
    * Scala API:
    * The raw properties of the kafka-clients driver, see constants in