Как в kafka передать пакет сообщений?

Question

[Rammstein007]

Сейчас передается по одному сообщению как передать пачку сообщений? Ниже код который передает по одному сообщению.

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

[Loli E1ON]

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

Comments

[Rammstein007]

Спасибо

Answer 2

[Igor Cherny]

нет такого подхода для бизнес логики, Kafka client за кулисами сам формирует пакеты сообщений для отправки, граничный размер и время формирования которых вы можете менять настройками конфигурации (batch.size, linger.ms) и которые будут отправлены в один и тот же partition. Учитывая, что выбор partition может основываться на ключе сообщения, составление пакетов в ручную (в бизнес коде) может создать дополнительные проблемы.

Comments

[Rammstein007]

Спасибо