Description
When setting batch.size to 0 for producer I get the following exception when sending a record:
java.lang.NullPointerException at org.apache.kafka.common.utils.Utils.notNull(Utils.java:315) at org.apache.kafka.clients.producer.internals.RecordAccumulator.append(RecordAccumulator.java:197) at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:478) at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:440) at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:360) at KafkaProducerTest.exposeNpeOnBatchSizeZero(KafkaProducerTest.java:21)
But documentation says:
... (a batch size of zero will disable batching entirely).
Please, see attached test.
Attachments
Attachments
Issue Links
- links to