Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Understanding the max.inflight property of kafka producer

can vert.x event bus replace the need for Kafka?

Kafka Topic vs Partition topic

Kafka in Kubernetes Cluster- How to publish/consume messages from outside of Kubernetes Cluster

Can a Kafka producer create topics and partitions?

Spark structured streaming kafka convert JSON without schema (infer schema)

How to achieve delayed queue with apache kafka?

Kafka Streams and RPC: is calling REST service in map() operator considered an anti-pattern?

Difference between idempotence and exactly-once in Kafka Stream

what happens after a broker is down in a cluster?

apache-kafka

Kafka Consumer outputs excessive DEBUG statements to console (ecilpse)

Kafka Rebalancing. Duplicate processing issue

kafka AdminClient API Timed out waiting for node assignment

How can I handle IOException when Kafka is down?

Dynamically connecting a Kafka input stream to multiple output streams

Dead letter queue (DLQ) for Kafka with spring-kafka

org.apache.kafka.common.KafkaException: Failed to construct kafka consumer

How to find the root cause of high CPU usage of Kafka brokers?

apache-kafka

Use schema to convert AVRO messages with Spark to DataFrame

Kafka Rebalancing and listeners pitfalls

apache-kafka rebalancing