Skip to content

Commit 179987e

Browse files
GH-3057: New receiveBatch method on RKCT
Fixes: #3057 * Adding wrapper method `receiveBatch` in ReactiveKafkaConsumerTemplate that delegates to `KafkaReceiver#receiveBatch.` * Addressing PR review.
1 parent f28ee55 commit 179987e

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

0 commit comments

Comments
 (0)