Skip to content

Commit

Permalink
GH-1693: Use concatMap in ReactiveKafkaTemplate
Browse files Browse the repository at this point in the history
Fixes #1693

The documentation of the `reactor-kafka` project states that messages should be consumed 
using the `concatMap` operator, but the `ReactiveKafkaConsumerTemplate` uses the `flatMap`
operator at least in case of the `receiveAutoAck` method.
  • Loading branch information
oemergenc committed Jan 27, 2021
1 parent 5e46e02 commit 9101166
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,7 @@ public Flux<ReceiverRecord<K, V>> receive() {
}

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

public Flux<ConsumerRecord<K, V>> receiveAtMostOnce() {
Expand Down

0 comments on commit 9101166

Please sign in to comment.