Невозможно опубликовать сообщения на Кафке - PullRequest
Новая
       16

Невозможно опубликовать сообщения на Кафке

0 голосов
/ 13 апреля 2019

Мне нужно отправить два события на кафку. Я могу нажать одно. Я получаю Арифметическое Исключение, выдвигая второе. Я использую Spring-Kafka. 

   public Map<String, Object> producerConfigs() {
        Map<String, Object> props = new HashMap<>();
        // list of host:port pairs used for establishing the initial connections to the Kakfa cluster
        props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
        props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
        props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, JsonSerializer.class);
        return props;
    }

//sending using kafka-template
kafkaTemplate.send(subscriptionTopic, subscriptionEvent);


2019-04-13 09:39:49:189 [kafka-producer-network-thread | producer-1] [/] ERROR org.apache.kafka.clients.producer.internals.Sender:164 - Uncaught error in kafka producer I/O thread: 
java.lang.ArithmeticException: / by zero
    at org.apache.kafka.clients.producer.internals.RecordAccumulator.drain(RecordAccumulator.java:438) ~[kafka-clients-0.11.0.2.jar:?]
    at org.apache.kafka.clients.producer.internals.Sender.sendProducerData(Sender.java:254) ~[kafka-clients-0.11.0.2.jar:?]
    at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:223) ~[kafka-clients-0.11.0.2.jar:?]
    at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:162) [kafka-clients-0.11.0.2.jar:?]
    at java.lang.Thread.run(Thread.java:748) [?:1.8.0_171]

исключение наступает непрерывно .... как в цикле

...