Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

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

Kafka: Is our number of partitions insane?

apache-kafka

How to fix kafka.common.errors.TimeoutException: Expiring 1 record(s) xxx ms has passed since batch creation plus linger time

What is the optimal way to read from multiple Kafka topics and write to different sinks using Spark Structured Streaming?

kafka consumer in R

python r apache-kafka

Apache Kafka Consumer group and Simple Consumer

apache-kafka

multiprocessing in kafka-python

Why not let consumers pull messages from followers?

apache-kafka

Check all the lags in Kafka

apache-kafka

Spring kafka consumer, seek offset at runtime?

What happens if I don't close the kafka producer

Kafka Stream count on time window not reporting zero values