From 09b61991ff33c966cbceeb7686a3342304428256 Mon Sep 17 00:00:00 2001
From: Artem Bilan <artem.bilan@broadcom.com>
Date: Fri, 20 Dec 2024 11:10:41 -0500
Subject: [PATCH] KafkaDslTests: change group for MS in attempt to mitigate
 seeks

---
 .../springframework/integration/kafka/dsl/KafkaDslTests.java  | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

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();