Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

How do I configure spring-kafka to ignore messages in the wrong format?

Maximum subscription limit of Kafka Topics Per Consumer

KafkaIO checkpoint - how to commit offsets to Kafka

Kafka connector logs

Kafka Streams closing processor's state store

How to join multiple Kafka topics?

Kafka Streams: Is it possible to have "compact,delete" policy on state stores?

Automatic change kafka topic partition leader

apache-kafka

Use message key in Kafka connect source connector

Adding new ZooKeeper node in Kafka cluster?

Kafka ordering with multiple producers on same topic and parititon

apache-kafka

Kafka broker auto scaling

apache-kafka

Are there any problems with this way of starting an infinite loop in a Spring Boot application?

During rolling upgrade/restart, how to detect when a kafka broker is "done"?

apache-kafka upgrade

TypeError: Client is not a constructor - error at the latest version of kafka-node

node.js apache-kafka mosca

Consumer and producer failing with error: "Connection to 0 was disconnected before the response was read"

How to stream large files through Kafka?

java apache-kafka

What happens to persistent volume if the StatefulSet got deleted and re-created?

kubernetes apache-kafka

Kafka MirrorMaker 2.0 duplicate each messages

What is the difference between MANUAL and MANUAL_IMMEDIATE in spring-kafka AckMode