Simple Kafka Streams data pipeline

KafkaStreamsSimpleDataPipeline.java

streamBuilder
    .stream(
            STRING_SERDE, STRING_SERDE, upstreamTopicName
    ).filter((messageKey, messageBody) -> {
        try {
            Double.parseDouble(messageBody);
            return true;
        } catch (Throwable e) {
            return false;
        }
    }
).map((messageKey, messageBody) -> {
    BigDecimal numericMessage = new BigDecimal(messageBody);
    Temperature temperature = Temperature.apply(numericMessage);
    return new KeyValue<>(messageKey, temperature);
}).to(STRING_SERDE, avroSerde, downstreamTopicName);