We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2378f3f commit 09b6199Copy full SHA for 09b6199
spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java
@@ -389,8 +389,10 @@ public DefaultKafkaHeaderMapper mapper() {
389
390
@Bean
391
public IntegrationFlow sourceFlow() {
392
+ ConsumerProperties consumerProperties = new ConsumerProperties(TEST_TOPIC3);
393
+ consumerProperties.setGroupId("inboundChannelAdapterGroup");
394
return IntegrationFlow
- .from(Kafka.inboundChannelAdapter(consumerFactory(), new ConsumerProperties(TEST_TOPIC3)),
395
+ .from(Kafka.inboundChannelAdapter(consumerFactory(), consumerProperties),
396
e -> e.poller(Pollers.fixedDelay(100)))
397
.handle(p -> {
398
this.fromSource = p.getPayload();
0 commit comments