Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Kafka consumer gets stuck after exceeding max.poll.interval.ms

kafka as event store in event sourced system

When does kafka change leader?

apache-kafka

Spring Kafka producers throwing TimeoutExceptions

Using AWS glue schema registry with confluent SerDe clients

Single or multiple topic (stream) per Aggregate Root event in kafka

Python: how to mock a kafka topic for unit tests?

Kafka Streams error - Offset commit failed on partition, request timed out

Kafka consumer "failed to find leader" when fetching topic metadata

Max number of tuple replays on Storm Kafka Spout

apache-kafka apache-storm

kafka + how to calculate the value of log.retention.byte

apache-kafka

Does commitOffsets on high-level consumer block?

Kubernetes - Can't connect to a service IP from the service's pod

apache-kafka kubernetes

How to read records from Kafka topic from beginning in Spark Streaming?

Kafka Streams: Proper way to exit on error

Apache Pulsar vs. Apache RocketMQ [closed]

Kafka -> Flink DataStream -> MongoDB

Can we update/Upsert a record in mongodb? data source is kafka

How to manually set group.id and commit kafka offsets in spark structured streaming?

How to set group.id for consumer group in kafka data source in Structured Streaming?