I'm getting message timeouts sometimes even with a 4 minute timeout stated. This seems to happen more frequently when I send lots of small messages (like 90K messages of 4 or 5 bytes each). I am requesting an ack.required of 2. (on a 3 node cluster) Is there anyway to have the message timeout indicate which brokers it's waiting on? Or does it not have any idea and it's the job of the leader of the partition to simply tell the client that 2 got it?