Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka-streams

Read data from KSQL tables

Kafka Streams - Retrying a message

apache-kafka-streams

Failed to delete the state directory in IDE for Kafka Stream Application

Use kafka to detect changes on values

Kafka Streams 2.5.0 requires input topic

Kafka Processor API: Different key for Source and StateStore?

Aggregate over multiple partitions in Kafka Streams

Kafka GlobalKTable Latency Issue

How does kafka streams compute watermarks?

How to change timestamp of records?

java apache-kafka-streams

KTable state store persistence

apache-kafka-streams

Kafka Streams Testing : java.util.NoSuchElementException: Uninitialized topic: "output_topic_name"

kafka streams session window retention duration

Why does co-partitioning of two Kstreams in kafka require same number of partitions for both the streams?

Streaming messages from one Kafka Cluster to another

Streaming from particular partition within a topic (Kafka Streams)

Does the Kafka streams aggregation have any ordering guarantee?

apache-kafka-streams

Kafka Streams - SerializationException: Unknown magic byte

Kafka Stream offset reset to zero for consumer group

How does Kafka Streams work with Partitions that contain incomplete Data?