Skip to main content

All Questions

1 vote
0 answers
311 views

Kafka consumer : Maximum consumer rate

I am interested in learning/deducing the maximum consumption rate of a Kafka consumer in my consumer group. Maximum consumption rate is the rate at which the consumer can not keep up with the message ...
Mazen Ezzeddine's user avatar
-1 votes
1 answer
818 views

Kafka: Write custom partitioner or just use Key?

So I have a Kafka topic with multiple partitions and on it I'm producing messages. I want my messages to be partitioned based on user id. I can achieve this either by using UserId as the message key ...
Richo's user avatar
  • 761
2 votes
2 answers
1k views

Kafka deep healthcheck

We've recently run into an issue where a Kafka broker encountered a kernel issue which blocked IO (but was able to heartbeat back to zookeeper I guess). The result of this is that the Kafka broker ...
hankduan's user avatar
  • 6,034
3 votes
1 answer
5k views

Killing node with __consumer_offsets leads to no message consumption at consumers

I have 3 node(nodes0,node1,node2) Kafka cluster(broker0, broker1, broker2) with replication factor 2 and Zookeeper(using zookeeper packaged with Kafka tar) running on a different node (node 4). I had ...
FindingTheOne's user avatar
12 votes
2 answers
12k views

Desigining Kafka Topics - Many Topics vs One Big Topic

Considering a stream of different events the recommended way would be one big topic containing all events multiple topics for different types of events Which option would be better? I understand ...
user3452075's user avatar
2 votes
1 answer
2k views

Is it possible to put a binary file (say a .mp3 file) as a single message in Kafka? If yes, how?

I am relatively new to Apache Kafka. As a part of a tiny project, I was trying to put a text log file in Kafka as a single message. I encountered some encoding errors. Kafka's java API (as I ...
Chitral Verma's user avatar
3 votes
1 answer
3k views

Kafka cluster zookeeper failure handling

I am going to implement a kafka cluster consisting of 3 machines, one for zookeeper and other 2 as brokers. I have about 6 consumer machines and about hundred producers. Now if one of the broker ...
Shades88's user avatar
  • 8,370