Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

How Spark RDD partitions are processed if no. of executors < no. of RDD partition

Kafka command line producer/consumer have 1 second latency

Spring Kafka Partitioning

Is there a Python API for event-driven Kafka consumer?

Kafka broker is not available from localhost

How to monitor consumer lag in kafka via jmx?

Spring Actuator + Kafka Streams - Add kafka stream status to health check endpoint

In Kafka HA, why minimum number of brokers required are 3 and not 2

Unable to start any kafka processes

apache-kafka

Is the --group option deprecated from kafka-console-consumer tool? if so, how can I set the consumer group using kafka-console-consumer.

Work distribution with Kafka Streams

Apache Kafka LEADER_NOT_AVAILABLE

java queue apache-kafka

How to create unit test with kafka embedded in the spring cloud stream

Understand Confluent Control Center

Kafka Connect failed to start

Which jmx metric should be used to monitor the status of a connector in kafka connect?

Kafka - Deserializing the object in Consumer

Check for the existence of a Kafka topic programatically in Java

java apache-kafka

kafka jar does not include kafka.utils.testutils

Kafka partition key not working properly‏

scala apache-kafka