Я пытаюсь отправить данные из kafka нескольким получателям, используя несколько производителей kafka.Но когда я пытаюсь получить разделы для каждой темы кафки, я получаю исключение как:
org.apache.kafka.common.errors.InterruptException: java.lang.InterruptedException в org.apache.kafka.clients.producer.KafkaProducer.partitionsFor (KafkaProducer.java:559) в com.gene.opscenter.snmpconnector.KafkaUtils.partitions (KafkaUtils.java:148)
1006 * Я сделал метод, которыйвыборка номера раздела из каждой темы:
org.apache.kafka.clients.producer.Producer producer = null;
List partitionList = producer.partitionsFor(topic);
Этот метод partitionsFor дает прерывистое исключение.
Я не могу понять при увеличении количества потоков, почему он дает прерванное исключение.
Буду признателен за любую помощь.