Use unique Kafka consumer groups in tests

artembilan · artembilan · commit a667171c4f33 · 2022-10-06T10:50:01.000-04:00
so, it doesn't cause unexpected rebalances in the global shared embedded Kafka broker
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
@@ -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")
 				}
 
 	}

Original file line number	Diff line number	Diff line change
`@@ -328,7 +328,7 @@ class KafkaDslKotlinTests {`
`328`	`328`
`329`	`329`	`private fun replyContainer(): GenericMessageListenerContainer<Int, String> {`
`330`	`330`	`val containerProperties = ContainerProperties(TEST_TOPIC5)`
`331`		`- containerProperties.setGroupId("outGate")`
	`331`	`+ containerProperties.setGroupId("kotlinOutGate")`
`332`	`332`	`containerProperties.setConsumerRebalanceListener(object : ConsumerRebalanceListener {`
`333`	`333`
`334`	`334`	`override fun onPartitionsRevoked(partitions: Collection<TopicPartition>) {`
`@@ -352,7 +352,7 @@ class KafkaDslKotlinTests {`
`352`	`352`	`private fun containerProperties() =`
`353`	`353`	`ContainerProperties(TEST_TOPIC4)`
`354`	`354`	`.also {`
`355`		`- it.setGroupId("inGateGroup")`
	`355`	`+ it.setGroupId("kotlinInGateGroup")`
`356`	`356`	`}`
`357`	`357`
`358`	`358`	`}`