Skip to content

Commit

Permalink
GH-3057: New receiveBatch method on RKCT
Browse files Browse the repository at this point in the history
Fixes: #3057 

* Adding wrapper method `receiveBatch` in ReactiveKafkaConsumerTemplate
   that delegates to `KafkaReceiver#receiveBatch.` 
* Addressing PR review.
  • Loading branch information
marcusvoltolim authored Mar 18, 2024
1 parent f28ee55 commit 179987e
Showing 1 changed file with 6 additions and 1 deletion.
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
/*
* Copyright 2019-2023 the original author or authors.
* Copyright 2019-2024 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
Expand Down Expand Up @@ -50,6 +50,7 @@
*
* @author Mark Norkin
* @author Adrian Chlebosz
* @author Marcus Voltolim
*
* @since 2.3.0
*/
Expand All @@ -71,6 +72,10 @@ public Flux<ReceiverRecord<K, V>> receive() {
return this.kafkaReceiver.receive();
}

public Flux<Flux<ReceiverRecord<K, V>>> receiveBatch() {
return this.kafkaReceiver.receiveBatch();
}

public Flux<ConsumerRecord<K, V>> receiveAutoAck() {
return this.kafkaReceiver.receiveAutoAck().concatMap(Function.identity());
}
Expand Down

0 comments on commit 179987e

Please sign in to comment.