How to send a batch of messages to kafka?

Question

Java

Now one message is transmitted how to send a bunch of messages? Below is the code that sends one message at a time.

public void sendMessages(List<EntryTestJson> msgList)
    {
        String topic = "test";
        try (Producer<String, String> producer = createProducer())
        {
            for (EntryTestJson message : msgList)
            {
                ProducerRecord<String, String> record = new ProducerRecord<>(topic, message.toString());
                producer.send(record, new RecordCallback());
                producer.flush();
                log.info("Отправлено сообщение: " + record.value());
            }
        } catch (Exception e)
        {
            log.error("Ошибка при отправке сообщения", e);
        }
    }

Answer 1

https://stackoverflow.com/questions/31275065/is-ka...

Answer 2

there is no such approach for business logic, Kafka client behind the scenes itself generates message batches for sending, the boundary size and formation time of which you can change with configuration settings (batch.size, linger.ms) and which will be sent to the same partition. Given that partition selection can be based on a message key, manually composing packages (in business code) can create additional problems.