Kafka Streams KStream.map metodu

Örnek

Şöyle yaparız

stream.map(new KeyValueMapper<String, String, KeyValue<String, String>>() {
  @Override
  public KeyValue<String, String> apply(String k, String v) {
    return new KeyValue<>(k.toUpperCase(), v.toUpperCase());
  }
});