Народ, подскажите, пожалуйста, а куда смотреть, что бы разогнать consumer

(увеличит throughput) без добавления новых партиций? К сожалению, confluent cloud не умеет добавлять новые партиции через UI.

Мой кейс следующий: есть consumer, который написан с использованием spring Kafka binder streams. Он читает из топика, делает конвертацию и делает post request на внешний http. У топика одна партиция.

Сделай ещё один топик с кучей партиций, гони в него, а уже потом делай вюс тяжёлую логику

Все таки хотелось бы разогнать сам consumer, а потом уже горизонтально скейлиться.

поиграться с размером батча

https://medium.com/@vijaya.cigala/consuming-messages-in-batch-mode-in-kafka-using-spring-cloud-stream-kafka-binder-28d782f979cc

Что значит "на лету не умеет"?

Так не работает

В UI Confluent Cloud нет опции обновления количества партиций после того как создан новый топик.

Что ты имеешь ввиду?

А если через cli? https://docs.confluent.io/ccloud-cli/current/command-reference/kafka/topic/ccloud_kafka_topic_update.html

Не пробовал. Но будет странно, что можно будет через cli обновить количество партиций, но нельзя через web морду.

Я не буду удивлен

Also, в саппорт писал?

Неа. Пока что руки не дошли до саппорта.