From 27adac1783e44836dacf585cf43be203f6a1d32c Mon Sep 17 00:00:00 2001 From: Aleksey Isachenkov Date: Tue, 13 Aug 2019 20:27:26 +0300 Subject: [PATCH 1/2] Updated kafka version to 2.3.0. Added group instance id setter. --- core/src/main/scala/akka/kafka/ConsumerSettings.scala | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/core/src/main/scala/akka/kafka/ConsumerSettings.scala b/core/src/main/scala/akka/kafka/ConsumerSettings.scala index 547ab3a43..c32a6cec0 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 From 0d43cb8ee05e7b64276adbc0832494a23fe0f8fa Mon Sep 17 00:00:00 2001 From: Enno Runne <458526+ennru@users.noreply.github.com> Date: Mon, 2 Dec 2019 10:16:36 +0100 Subject: [PATCH 2/2] Scalafmt --- core/src/main/scala/akka/kafka/ConsumerSettings.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/core/src/main/scala/akka/kafka/ConsumerSettings.scala b/core/src/main/scala/akka/kafka/ConsumerSettings.scala index c32a6cec0..1a07cc799 100644 --- a/core/src/main/scala/akka/kafka/ConsumerSettings.scala +++ b/core/src/main/scala/akka/kafka/ConsumerSettings.scala @@ -234,8 +234,8 @@ class ConsumerSettings[K, V] @InternalApi private[kafka] ( withProperty(ConsumerConfig.GROUP_ID_CONFIG, groupId) /** - * An id string that marks consumer as a unique static member of the consumer group. - */ + * 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)