Skip to content

Commit cae667e

Browse files
committed
Fix KafkaStreamBrancher doc typos
Fixes #1459
1 parent 90c4c24 commit cae667e

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
@@ -169,7 +169,7 @@ stream.through(new JsonSerde<>(MyKeyType.class)
169169
----
170170
====
171171

172-
==== Using `KafkaStreamsBrancher`
172+
==== Using `KafkaStreamBrancher`
173173

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

@@ -194,7 +194,7 @@ The following example uses `KafkaStreamBrancher`:
194194
====
195195
[source,java]
196196
----
197-
new KafkaStreamsBrancher<String, String>()
197+
new KafkaStreamBrancher<String, String>()
198198
.branch((key, value) -> value.contains("A"), ks -> ks.to("A"))
199199
.branch((key, value) -> value.contains("B"), ks -> ks.to("B"))
200200
//default branch should not necessarily be defined in the end of the chain!

0 commit comments

Comments
 (0)