Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

How to get latest offset for a partition for a kafka topic?

Kafka Connect running out of heap space

getting "org.apache.kafka.common.network.InvalidReceiveException: Invalid receive (size = 1195725856 larger than 104857600)"

apache-kafka

Increase the number of messages read by a Kafka consumer in a single poll

apache-kafka

Monitoring UI for Apache kafka - kafka manager vs kafka monitor [closed]

apache-kafka jms monitoring

Kafka consumer for multiple topic

How does Kafka store offsets for each topic?

How do I delete/clean Kafka queued messages without deleting Topic

apache-kafka

UnsatisfiedLinkError: /tmp/snappy-1.1.4-libsnappyjava.so Error loading shared library ld-linux-x86-64.so.2: No such file or directory

Confluent Maven repository not working?

Kafka how to read from __consumer_offsets topic

Kafka: unable to start Kafka - process can not access file 00000000000000000000.timeindex

what is difference between partition and replica of a topic in kafka cluster

hadoop apache-kafka

Kafka and firewall rules

Kafka Consumer default Group Id

How to create topics in apache kafka?

Why does kafka producer take a broker endpoint when being initialized instead of the zk

apache-kafka

How does consumer rebalancing work in Kafka?

How does an offset expire for an Apache Kafka consumer group?

apache-kafka

Bootstrap server vs zookeeper in kafka?