mirror of https://github.com/apache/kafka.git
d8fe204376
Non-existent methods show up in the doc:
builder.from("my-input-topic").mapValue(value -> value.length().toString()).to("my-output-topic");
There is no method named from or mapValues. They should be stream and mapValues respectively.
Reviewers: Matthias J. Sax <matthias@confluent.io>
|
||
|---|---|---|
| .. | ||
| examples/src/main/java/org/apache/kafka/streams/examples | ||
| src | ||