diff --git a/spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java b/spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java
index 645b7bc6e3..930f50da36 100644
--- a/spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java
+++ b/spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java
@@ -389,8 +389,10 @@ public class KafkaDslTests {
 
 		@Bean
 		public IntegrationFlow sourceFlow() {
+			ConsumerProperties consumerProperties = new ConsumerProperties(TEST_TOPIC3);
+			consumerProperties.setGroupId("inboundChannelAdapterGroup");
 			return IntegrationFlow
-					.from(Kafka.inboundChannelAdapter(consumerFactory(), new ConsumerProperties(TEST_TOPIC3)),
+					.from(Kafka.inboundChannelAdapter(consumerFactory(), consumerProperties),
 							e -> e.poller(Pollers.fixedDelay(100)))
 					.handle(p -> {
 						this.fromSource = p.getPayload();