Skip to content

Commit 0fd6665

Browse files
spring-projectsGH-3057: ReactiveKafkaConsumerTemplate missing receiveBatch method
* Adding wrapper method `receiveBatch` in ReactiveKafkaConsumerTemplate. Closes spring-projects#3057
1 parent 0b321cf commit 0fd6665

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

spring-kafka/src/main/java/org/springframework/kafka/core/reactive/ReactiveKafkaConsumerTemplate.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright 2019-2023 the original author or authors.
2+
* Copyright 2019-2024 the original author or authors.
33
*
44
* Licensed under the Apache License, Version 2.0 (the "License");
55
* you may not use this file except in compliance with the License.
@@ -50,6 +50,7 @@
5050
*
5151
* @author Mark Norkin
5252
* @author Adrian Chlebosz
53+
* @author Marcus Voltolim
5354
*
5455
* @since 2.3.0
5556
*/
@@ -71,6 +72,10 @@ public Flux<ReceiverRecord<K, V>> receive() {
7172
return this.kafkaReceiver.receive();
7273
}
7374

75+
public Flux<ReceiverRecord<K, V>> receiveBatch() {
76+
return this.kafkaReceiver.receiveBatch().concatMap(Function.identity());
77+
}
78+
7479
public Flux<ConsumerRecord<K, V>> receiveAutoAck() {
7580
return this.kafkaReceiver.receiveAutoAck().concatMap(Function.identity());
7681
}

0 commit comments

Comments
 (0)