Возможно ли реализовать динамическое дозирование c с помощью Kafka Producer?

Question

Сейчас я делаю несколько тестов с Apache Кафкой. В конфигурации Kafka Producer параметры batch.size и linger.ms управляют стратегией пакетирования. Можно ли сделать эти параметры динамически при производстве? Например, если скорость приема данных быстро возрастает, мы можем увеличить batch.size , чтобы накапливать больше сообщений в пакете. Я не смог найти ни одного примера динамического c пакетирования с Kafka Producer. Возможно ли реализовать?

Answer 1

Это возможно, но вам придется самостоятельно закрывать и заново открывать новый экземпляр Producer с обновленными конфигурациями во время выполнения, при этом убедитесь, что вы не сбрасываете события между этими действиями.