Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Kafka Restart from same offset

java apache-kafka

Why do we have __consumer_offsets partitions default value 50?

apache-kafka

Does Kafka replaces the Load Balancers completely?

Getting latest message timestamp in my Kafka queue

Does updating broker settings (topic defaults) change already existing topics?

KafkaTool: Can't connet to Kafka cluster

Spring Integration and Kafka: How to filter messages based on message header

Unfair Leader election in Kafka - Same leader for all partitions

apache-kafka

Docker Compose with Zookeeper, Kafka, Redis, and Java Spring Boot

How to read batch messages in confluent kafka python?

ElasticsearchSinkConnector Failed to deserialize data to Avro

How to migrate consumer offsets using MirrorMaker 2.0?

Kafka in docker-compose: topics not in preferred replica for broker

Can't set Kafka retention policy to both compact and delete

apache-kafka

How does Spring Kafka manual commit works in Batch listener mode

Two strange bytes at the beginning of each message of a Kafka message produced by my Kafka Connector

Kafka KStreams Issue in Aggregation with Time Window

Spring App Not Connecting to Kafka with SSL

Will the messages get deleted even if it's not consumed in Kafka

apache-kafka

The meaning of 'request.timeout.ms' of Kafka producer makes me confused