Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Apache-Kafka, batch.size vs buffer.memory

How to write Unit test for @KafkaListener?

Smart Broker vs. Dumb Broker (Kafka and RabbitMQ)

rabbitmq apache-kafka

Spark Streaming from Kafka has error numRecords must not be negative

How to connect Kafka with Elasticsearch?

Back pressure in Kafka

When to use ConcurrentKafkaListenerContainerFactory?

Kafka Avro Consumer with Decoder issues

Kafka Streams - Send on different topics depending on Streams Data

Kafka offset management: enable.auto.commit vs enable.auto.offset.store

"kafka.zookeeper.ZooKeeperClientTimeoutException: Timed out waiting for connection" ONLY DURING LISTING TOPICS

KafkaUtils class not found in Spark streaming

No current assignment for partition occurs even after poll in Kafka

Spring Kafka: Multiple Listeners for different objects within an ApplicationContext

Kafka - is it possible to alter Topic's partition count while keeping the change transparent to Producers and Consumers?

apache-kafka

how to get the all messages in a topic from kafka server

kafka loses all topics on reboot

apache-kafka

Need to understand kafka broker property "log.flush.interval.messages"

apache-kafka

Kafka Multi Node setup "Unreasonable length" in Zookeeper logs

Containerized Kafka client errors when producing messages to the host Kafka server

docker apache-kafka