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")
 				}
 
 	}