Hello,

I am experimenting sending data to kafka using KafkaProducer and found that
when a partition is completely offline, e.g. a topic with replication
factor = 1 and some broker is down, KafkaProducer seems to be hanging
forever. Not even exit with the timeout setting. Can you take a look?

I checked code and found that the partitioner create partition based on the
total partition number - including those offline partitions. Is it possible
that we change ProducerClient to ignore offline partitions?


Thanks,

-Xiaoyu

Reply via email to