Skip to content

Commit 09b6199

Browse files
committed
KafkaDslTests: change group for MS in attempt to mitigate seeks
1 parent 2378f3f commit 09b6199

File tree

1 file changed

+3
-1
lines changed
  • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl

1 file changed

+3
-1
lines changed

spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -389,8 +389,10 @@ public DefaultKafkaHeaderMapper mapper() {
389389

390390
@Bean
391391
public IntegrationFlow sourceFlow() {
392+
ConsumerProperties consumerProperties = new ConsumerProperties(TEST_TOPIC3);
393+
consumerProperties.setGroupId("inboundChannelAdapterGroup");
392394
return IntegrationFlow
393-
.from(Kafka.inboundChannelAdapter(consumerFactory(), new ConsumerProperties(TEST_TOPIC3)),
395+
.from(Kafka.inboundChannelAdapter(consumerFactory(), consumerProperties),
394396
e -> e.poller(Pollers.fixedDelay(100)))
395397
.handle(p -> {
396398
this.fromSource = p.getPayload();

0 commit comments

Comments
 (0)