ConsumerSetting: Add group instance id setter (#861)

akka · Dec 2, 2019 · b12496f · b12496f
1 parent 5e3b1b8
commit b12496f
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/core/src/main/scala/akka/kafka/ConsumerSettings.scala b/core/src/main/scala/akka/kafka/ConsumerSettings.scala
@@ -233,6 +233,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