Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

How to monitor messages rate in Kafka topics?

Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 1001: org.apache.kafka.common.errors.DisconnectException

How to make Spark Streaming (Spark 1.0.0) read the latest data from Kafka (Kafka Broker 0.8.1)

Not able to connect to kafka server on google compute engine from local machine

Kafka: No message seen on console consumer after message sent by Java Producer

java apache-kafka

kafka on kubernetes cannot produce/consume topics (ClosedChannelException, ErrorLoggingCallback)

Sending data with kafka-python only working when briefly delaying code

Why do we need to mention Zookeeper details even though Apache Kafka configuration file already has it?

Kafka cached zkVersion not equal to that in zookeeper broker not recovering

Choosing the right cleanup policy in Kafka configuration

apache-kafka

How does Kinesis achieve Kafka style Consumer Groups?

How to set auto.create.topics.enable as default config on AWS MSK cluster

Kubernetes pod resolve external kafka hostname in coredns not as hostaliases inside pod

Kafka - Stream vs Topic

how to delete kafka message after reading

python apache-kafka

How to make kafka-python or pykafka work as an async producer with uwsgi and gevent?

Kafka uncommitted messages

apache-kafka

Can I retrieve the latest available offset for a Kafka partition without retrieving all the messages?

Multithreaded Kafka Consumer or PerPartition-PerConsumer

Failed to rebalance error in Kafka Streams with more than one topic partition