Группа потребителей привязки Spring Cloud Stream и конфигурация идентификатора клиентаJAVA

Программисты JAVA общаются здесь
Ответить
Anonymous
 Группа потребителей привязки Spring Cloud Stream и конфигурация идентификатора клиента

Сообщение Anonymous »

У меня есть тема 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
Ответить

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

Вернуться в «JAVA»