весна-облако-поток-кафка не уважает одного потребителя для группы

Я использую spring-cloud-stream-kafka. Я запускаю 2 экземпляра потребительского приложения с одним и тем же именем группы testGroup, потребляющих сообщения из темы Kafka testTopic с одним разделом, я ожидал, что один из экземпляров-потребителей будет потреблять сообщения из темы Kafka и другого экземпляра, чтобы ничего не потреблять, поскольку они имеют одно и то же имя группы. Я использую клиент Kafka 0.8.xx. Вот мои свойства

spring.cloud.stream.bindings.input.destination=testTopic

spring.cloud.stream.bindings.input.group=testGroup

Есть идеи, что могло случиться?


apache-kafka spring-cloud-stream
person Amit Bartake    schedule 15.11.2016    source источник

Ответы (2)


arrow_upward
1
arrow_downward

Верно, это ожидаемое поведение для 1.0.3 / 0.8, где мы используем API SimpleConsumer. После версии 1.1 этого делать не нужно - см. http://docs.spring.io/spring-cloud-stream/docs/1.0.3.RELEASE/reference/htmlsingle/index.html#_instance_index_and_instance_count. для получения дополнительной информации.

person Marius Bogoevici    schedule 15.11.2016
comment
Означает ли это, что у меня не может быть TOPIC с одним разделом и иметь 2 экземпляра потребителей с одной и той же группой, указывающей на него, и иметь только один экземпляр, потребляющий сообщения. Мне нужно было настроить более 1 потребительского экземпляра для обеспечения отказоустойчивости - person Amit Bartake; 16.11.2016
comment
Нет, это означает, что вам необходимо следовать инструкциям в ссылке и настроить индекс экземпляра и количество экземпляров соответственно для каждого запущенного экземпляра. - person Marius Bogoevici; 18.11.2016

arrow_upward
0
arrow_downward

Какую версию Spring Cloud Stream вы используете? Я думаю, вы используете 1.0.3 версию Spring Cloud Stream, которая поддерживает 0.8.xx версию Kafka. Во всяком случае, это похоже на ошибку.

Кроме того, я не вижу этой проблемы при использовании Kafka 0.9 или 0.10 с Spring Cloud Stream 1.1.x.

person Ilayaperumal Gopinathan    schedule 15.11.2016
comment
Я использую Brixton.SR6, который тянет spring-cloud-starter-stream-kafka (1.0.2.RELEASE) - person Amit Bartake; 15.11.2016