Все потребители из группы потребителей получают сообщение

Question

Я написал приложение потока весеннего облака, чтобы получать сообщения из темы Кафки. Я пытаюсь настроить группу потребителей, так что, когда я масштабирую свое приложение, только один из экземпляров приложения получает сообщение из темы Кафка.

Ниже мой application.yml spring: cloud: stream: bindings: orderTopic: group: orderGroup destination: orderTopic kafka: binder: brokers: 192.168.61.21 defaultBrokerPort: 9092 zkNodes: 192.168.61.21 defaultZkPort: 2181 Я развернула приложение Cloud Foundry (pcfdev) и установить подсчитывать экземпляр для приложения к 2. Когда я отправить заказ на orderTopic тему, я ожидаю, что только один из 2 экземпляров приложения получают заказ, однако, оба экземпляра приложения получают такой же порядок, как показано ниже 2016-05-10T16:33:46.42-0600 [APP/0] OUT Order Number 23 received. 2016-05-10T16:33:47.42-0600 [APP/1] OUT Order Number 24 received. 2016-05-10T16:33:47.42-0600 [APP/0] OUT Order Number 24 received. 2016-05-10T16:33:48.42-0600 [APP/1] OUT Order Number 25 received. 2016-05-10T16:33:48.42-0600 [APP/0] OUT Order Number 25 received. 2016-05-10T16:33:49.43-0600 [APP/1] OUT Order Number 26 received. 2016-05-10T16:33:49.43-0600 [APP/0] OUT Order Number 26 received.

Можете ли вы помочь

Answer 1

Вот ссылка на то, что вам нужно сделать: http://docs.spring.io/spring-cloud-stream/docs/current-SNAPSHOT/reference/htmlsingle/#_instance_index_and_instance_count

Связующее Kafka нуждается в этой информации, чтобы правильно распределять разделы.

В рамках усилий Spring Cloud Stream 1.1.0.M1 мы обновляем до 0.9 клиента Kafka и автоматически присоединяем возможность (re) автоматически при добавлении новых экземпляров.