Skip to content

Instantly share code, notes, and snippets.

@TristinDavis
Forked from kijanowski/App.java
Created August 9, 2019 22:51
Show Gist options
  • Save TristinDavis/bd035043ca58342ce55c589ef4aeb323 to your computer and use it in GitHub Desktop.
Save TristinDavis/bd035043ca58342ce55c589ef4aeb323 to your computer and use it in GitHub Desktop.
StreamsBuilder builder = new StreamsBuilder();
builder
.stream("inJlinkTopic", Consumed.with(Serdes.String(), Serdes.String()))
.peek((key, value) -> log.info("Received message: {}", value))
.filter((key, value) -> "PASS".equals(value))
.to("outJlinkTopic", Produced.with(Serdes.String(), Serdes.String()));
KafkaStreams streams = new KafkaStreams(builder.build(), config);
streams.start();
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment