У меня есть тема Kafka с 20 разделами, и у меня есть Java-программа на основе потока Spring Cloud, которая принимает входные данные и создает выходные сообщения для настроенных тем Kafka.
На данный момент я запускается только один экземпляр программы, поэтому одна и та же группа ввода потребляет данные из всех 20 разделов.
Чтобы повысить эффективность, правильно ли запускать 4 экземпляра программы, чтобы использовать каждый из 5 разделов по настройка следующих свойств, уникальных для каждого экземпляра.
spring.cloud.stream.bindings.input.group=my-consumer-group
spring.cloud.stream.bindings.input.consumer.concurrency=5
spring.cloud.stream.kafka.binder.consumer.client.id=my-client-id (varying based on instance)
Подробнее здесь: https://stackoverflow.com/questions/788 ... figuration
