Hello. I'm a new who started learning the one of the new Kafka functionality, aka Kafka Stream.
As far as I know, the simplest usage of the Kafka Stream is to do something like parsing, which forward incoming data from a topic to another topic, with a few changing. So... Here is what I'd want to do: 1. Produce a simple message, like 1, 2, 3, 4, 5, ... from a producer 2. Let Kafka Stream application consume the message and change the message like [1], [2], [3], ... 3. Consume the changed message at a consumer I've read the documentation, https://kafka.apache.org/0102/javadoc/index.html?org/apache/kafka/connect, but it's unclear for me how to implement it. Especially, I could not understand the the line, builder.stream("my-input-topic").mapValues(value -> value.length().toString()).to("my-output-topic"). Could someone explain it and how to implement what I've mentioned? Thanks in advance. Best regards KIM
