Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka-streams

Kafka KTable - shared aggregation across machines

Why don't I see any output from the Kafka Streams reduce method?

Kafka Streams Persistent Store cleanup

Kafka Log Compacted Topic Duplication Values against same key not deleted

Work distribution with Kafka Streams

How to register a stateless processor (that seems to require a StateStore as well)?

java apache-kafka-streams

Why do the offsets of the consumer-group (app-id) of my Kafka Streams Application get reset after application restart?

Delaying Kafka Streams consuming

Kafka Streams with lookup data on HDFS

Kafka Streams - what is stored in memory and disk in Streams App

Avoiding Kafka Streams to start in tests using Spring Boot 1.5

Testing window aggregation with Kafka Streams

How can I assure consistency when using an event-carried state transfer approach in Kafka

Kafka stream: "TopicAuthorizationException: Not authorized to access topics" for an internal state store