Kafka Streams
java
StreamsBuilder builder = new StreamsBuilder();
KStream<String, String> stream = builder.stream("input-topic");
stream.filter((k, v) -> v.length() > 5)
.to("output-topic");