Skip to content

Commit 650b448

Browse files
committed
Fix KafkaStreamBrancher doc typos
Fixes #1459
1 parent 678d9d5 commit 650b448

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
lines changed

spring-kafka/src/main/java/org/springframework/kafka/support/KafkaStreamBrancher.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@
3131
* Example of usage:
3232
* <pre>
3333
* {@code
34-
* new KafkaStreamsBrancher<String, String>()
34+
* new KafkaStreamBrancher<String, String>()
3535
* .branch((key, value) -> value.contains("A"), ks->ks.to("A"))
3636
* .branch((key, value) -> value.contains("B"), ks->ks.to("B"))
3737
* //default branch should not necessarily be defined in the end
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@
3535
*
3636
* @since 2.2.4
3737
*/
38-
class KafkaStreamsBrancherTests {
38+
class KafkaStreamBrancherTests {
3939

4040
@Test
4141
@SuppressWarnings({ "unchecked", "rawtypes" })

src/reference/asciidoc/streams.adoc

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -136,7 +136,7 @@ stream.through(Serdes.Integer(), new JsonSerde<>(Cat.class), "cats");
136136

137137
IMPORTANT: Since Kafka Streams do not support headers, the `addTypeInfo` property on the `JsonSerializer` is ignored.
138138

139-
==== Using `KafkaStreamsBrancher`
139+
==== Using `KafkaStreamBrancher`
140140

141141
The `KafkaStreamBrancher` class introduces a more convenient way to build conditional branches on top of `KStream`.
142142

@@ -161,7 +161,7 @@ The following example uses `KafkaStreamBrancher`:
161161
====
162162
[source,java]
163163
----
164-
new KafkaStreamsBrancher<String, String>()
164+
new KafkaStreamBrancher<String, String>()
165165
.branch((key, value) -> value.contains("A"), ks -> ks.to("A"))
166166
.branch((key, value) -> value.contains("B"), ks -> ks.to("B"))
167167
//default branch should not necessarily be defined in the end of the chain!

0 commit comments

Comments
 (0)