Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-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

Kafka Stream from JSON to Avro

How to get windowed aggregation from kafka stream?

Kafka KStream-KTable join race condition

Is it possible to ReKey a GlobalKTable?

Spring Kafka - Event sourcing - Example of how to query some entity state using Kafka + KafkaStreams API