Skip to content

Commit

Permalink
Fix KafkaStreamBrancher doc typos
Browse files Browse the repository at this point in the history
Fixes #1459
  • Loading branch information
garyrussell committed Apr 21, 2020
1 parent 1d1a6a7 commit 444f928
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@
* Example of usage:
* <pre>
* {@code
* new KafkaStreamsBrancher<String, String>()
* new KafkaStreamBrancher<String, String>()
* .branch((key, value) -> value.contains("A"), ks->ks.to("A"))
* .branch((key, value) -> value.contains("B"), ks->ks.to("B"))
* //default branch should not necessarily be defined in the end
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@
*
* @since 2.2.4
*/
class KafkaStreamsBrancherTests {
class KafkaStreamBrancherTests {

@Test
@SuppressWarnings({ "unchecked", "rawtypes" })
Expand Down
4 changes: 2 additions & 2 deletions src/reference/asciidoc/streams.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -149,7 +149,7 @@ stream.through(new JsonSerde<>(MyKeyType.class)
----
====

==== Using `KafkaStreamsBrancher`
==== Using `KafkaStreamBrancher`

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

Expand All @@ -174,7 +174,7 @@ The following example uses `KafkaStreamBrancher`:
====
[source,java]
----
new KafkaStreamsBrancher<String, String>()
new KafkaStreamBrancher<String, String>()
.branch((key, value) -> value.contains("A"), ks -> ks.to("A"))
.branch((key, value) -> value.contains("B"), ks -> ks.to("B"))
//default branch should not necessarily be defined in the end of the chain!
Expand Down

0 comments on commit 444f928

Please sign in to comment.