From a667171c4f33aef869ff6a1b236478c64fdf37dc Mon Sep 17 00:00:00 2001
From: Artem Bilan <abilan@vmware.com>
Date: Thu, 6 Oct 2022 10:50:01 -0400
Subject: [PATCH] Use unique Kafka consumer groups in tests

so, it doesn't cause unexpected rebalances in the global shared embedded Kafka broker
---
 .../integration/kafka/dsl/kotlin/KafkaDslKotlinTests.kt       | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/spring-integration-kafka/src/test/kotlin/org/springframework/integration/kafka/dsl/kotlin/KafkaDslKotlinTests.kt b/spring-integration-kafka/src/test/kotlin/org/springframework/integration/kafka/dsl/kotlin/KafkaDslKotlinTests.kt
index 35b0de0004..4f993e00c1 100644
--- a/spring-integration-kafka/src/test/kotlin/org/springframework/integration/kafka/dsl/kotlin/KafkaDslKotlinTests.kt
+++ b/spring-integration-kafka/src/test/kotlin/org/springframework/integration/kafka/dsl/kotlin/KafkaDslKotlinTests.kt
@@ -328,7 +328,7 @@ class KafkaDslKotlinTests {
 
 		private fun replyContainer(): GenericMessageListenerContainer<Int, String> {
 			val containerProperties = ContainerProperties(TEST_TOPIC5)
-			containerProperties.setGroupId("outGate")
+			containerProperties.setGroupId("kotlinOutGate")
 			containerProperties.setConsumerRebalanceListener(object : ConsumerRebalanceListener {
 
 				override fun onPartitionsRevoked(partitions: Collection<TopicPartition>) {
@@ -352,7 +352,7 @@ class KafkaDslKotlinTests {
 		private fun containerProperties() =
 			ContainerProperties(TEST_TOPIC4)
 				.also {
-					it.setGroupId("inGateGroup")
+					it.setGroupId("kotlinInGateGroup")
 				}
 
 	}