Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka-streams

Why kafka streams state dir is in /tmp/kafka-streams?

End-of-window outer join with KafkaStreams

Spring Kafka and Kafka Streams

Kafka streams error : SerializationException: Size of data received by LongDeserializer is not 8

Kafka Stream topology optimization

apache-kafka-streams

Kafka stream vs kafka consumer how to make decision on what to use

Exception when processing data during Kafka stream process

The method withValueSerde() in the type Materialized<> is not applicable

apache-kafka-streams

How can do Functional tests for Kafka Streams with Avro (schemaRegistry)?

Intermittent WARN ConsumerCoordinator We received an assignment that doesn't match our current subscription

kafka ktable - rocksdb access via java

Issue with ArrayList Serde in Kafka Streams API

if i set value of commit.interval.ms = in kafka stream, Whether it will be able to commit offset?

Is it possible to get the latest value for a message key from kafka messages

KafkaStreams serde exception

Kafka Streams - reusing streams using through() vs toStream() + to()

Kafka Streams - Hopping windows - deduplicate keys

Kafka Streams: one record to multiple records