diff --git a/core/src/main/scala/akka/kafka/ConsumerSettings.scala b/core/src/main/scala/akka/kafka/ConsumerSettings.scala index 547ab3a43..1a07cc799 100644 --- 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