DEV Community

loading...

Terminate a Spring Boot application that uses Kafka-Streams and MongoDB

riccardo_cardin profile image Riccardo Cardin ・1 min read

I have a Spring Boot application that uses Kafka-Streams. In details, there is a stream that filters the messages it receives using the results of a query performed in MongoDB. The code is something similar to the following.

final KStream<String, String> stream =
    kStreamBuilder.stream(Serdes.String(), Serdes.String(), inputTopic)
                  .filter((s, message) -> service.hasSomeProperty(message))

Discussion (0)

pic
Editor guide