Skip to content

Instantly share code, notes, and snippets.

@mchmielarz

mchmielarz/plain_kafka_akka.java

Created December 15, 2020 10:25
Show Gist options
  • Save mchmielarz/606da311bda018eee58e544a01d04120 to your computer and use it in GitHub Desktop.
Save mchmielarz/606da311bda018eee58e544a01d04120 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
plain_kafka_akka.java
Consumer
.plainSource(consumerSettings, Subscriptions.topics(topicName))
.map(consumerRecord -> {
// processing logic comes here
return consumerRecord;
})
.runWith(Sink.ignore(), materializer)
.toCompletableFuture()
.handle(AppSupport.doneHandler())
.join();
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment