Posted on
2
1
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))For further actions, you may consider blocking this person and/or reporting abuse
Coherence is the first Platform-as-a-Service you can control. Unlike "black-box" platforms that are opinionated about the infra you can deploy, Coherence is powered by CNC, the open-source IaC framework, which offers limitless customization.
Lior Amsalem -
Ahmad Tibibi -
Turing -
Lior Amsalem -
Top comments (0)