Why does auto-commit enabled Kafka client commit latest produced message's offset during consume...

How do you return a future containing a list of messages after all available messages have been cons...

Fast Processing Topic and Slow Processing Topic - Akka Kafka...

Is this Akka Kafka Stream configuration benefits from Back Pressure mechanism of the Akka Streams?...

Is there functionality in the akka-Kafka (scala framework) to list all available topics...

Getting last message from kafka Topic using akka-stream-kafka when connecting with websocket...

Troubles with AVRO schema update...

Incompatible equality constraint while using Akka Kafka Streams...

Akka streams kafka commit offset after filter...

Using reactive-kafka to conditionally process messages...

What is a good pattern for committing Kafka consumer offset after processing message?...

Reactive-Kafka Stream Consumer: Dead letters occured...

Akka Stream TCP + Akka Stream Kafka producer not stopping not publishing messages and not error-ing ...