Skip to content

Commit 95e916d

Browse files
nhajratwolegz
authored andcommitted
Fix documentation typos
Signed-off-by: Nayan Hajratwala <[email protected]> Resolves #3110
1 parent 730ad0a commit 95e916d

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

docs/modules/ROOT/pages/kafka/kafka-reactive-binder/examples.adoc

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ public Function<Flux<String>, Flux<String>> uppercase() {
1111
}
1212
----
1313

14-
You can use the above `upppercase` function with both message channel based Kafka binder (`spring-cloud-stream-binder-kafka`) as well as the reactive Kafka binder (`spring-cloud-stream-binder-kafka-reactive`), the topic of discussion in this section.
14+
You can use the above `uppercase` function with both message channel based Kafka binder (`spring-cloud-stream-binder-kafka`) as well as the reactive Kafka binder (`spring-cloud-stream-binder-kafka-reactive`), the topic of discussion in this section.
1515
When using this function with the regular Kafka binder, although you are using reactive types in the application (i.e., in the `uppercase` function), you only get the reactive streams within the execution of your function.
1616
Outside the function's execution context, there is no reactive benefits since the underlying binder is not based on the reactive stack.
1717
Therefore, although this might look like it is bringing a full end-to-end reactive stack, this application is only partially reactive.
@@ -34,7 +34,7 @@ Starting with version 4.0.2, the `KafkaHeaders.ACKNOWLEDGMENT` header contains a
3434
[source, java]
3535
----
3636
@Bean
37-
public Consumer<Flux<Message<String>> consume() {
37+
public Consumer<Flux<Message<String>>> consume() {
3838
return msg -> {
3939
process(msg.getPayload());
4040
msg.getHeaders().get(KafkaHeaders.ACKNOWLEDGMENT, ReceiverOffset.class).acknowledge();

0 commit comments

Comments
 (0)