spring-cloud-stream-kafka no honra a un solo consumidor por un grupo

0

Estoy usando spring-cloud-stream-kafka . Estoy iniciando 2 instancias de una aplicación de consumidor con el mismo nombre de grupo testGroup consumiendo mensajes de un tema de Kafka testTopic con una sola partición, esperaba que una de las instancias de consumidor consumiera mensajes del tema de Kafka y la otra instancia no consumiera nada, ya que comparten el mismo nombre de grupo. Estoy usando la versión 0.8.xx del cliente Kafka . Aquí están mis propiedades

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

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

¿Alguna idea de lo que podría estar pasando?

1

Bien, ese es el comportamiento esperado para 1.0.3 / 0.8 donde usamos la API SimpleConsumer. No es necesario que lo haga después de 1.1; consulte http://docs.spring.io/spring-cloud-stream/docs/1.0.3.RELEASE/reference/htmlsingle/index.html#_instance_index_and_instance_count para obtener más detalles.

2
  • ¿Significa esto que no puedo tener un TEMA con una sola partición y tener 2 instancias de consumidores con el mismo grupo apuntando a él y que solo una instancia consume mensajes? Necesitaba configurar más de 1 instancia de consumidor para la resilienciaAmit Bartake 16/11/2016 a las 16:10
  • No, significa que debe seguir las instrucciones del enlace y configurar el índice de instancia y el recuento de instancias en consecuencia para cada instancia en ejecución. Marius Bogoevici 17/11/2016 a las 22:04
0

¿Qué versión de Spring Cloud Stream estás usando? Creo que está utilizando la 1.0.3versión de Spring Cloud Stream que es compatible con la 0.8.xxversión de Kafka . De todos modos, esto parece un error.

Además, no veo este problema cuando uso Kafka 0.9 o 0.10 con Spring Cloud Stream 1.1.x.

1
  • Estoy usando Brixton.SR6 que extrae spring-cloud-starter-stream-kafka (1.0.2.RELEASE)Amit Bartake 15 de nov. De 2016 a las 15:59