apache kafka - applications - Kafka 0.11 cómo restablecer las compensaciones

apache kafka windows

Question

Estoy intentando restablecer la compensación del consumidor con las últimas herramientas CLI para Kafka.

kafka-consumer-groups.bat --bootstrap-server kafka-host:9092 --group my-group --reset-offsets --to-earliest --all-topics

Como resultado veo esta salida:

TOPIC                            PARTITION  NEW-OFFSET
FirstTopic                       0          0
SecondTopic                      0          0

Pero corriendo de nuevo el comando:

kafka-consumer-groups.bat --bootstrap-server kafka-host:9092 --group my-group --describe

resultados en salida:

Consumer group ''my-group'' has no active members.

TOPIC              PARTITION  CURRENT-OFFSET  LOG-END-OFFSET  LAG
FirstTopic         0          1230            1230            0  
SecondTopic        0          1022            1022            0

He intentado otras opciones como restablecer el desplazamiento explícito o especificar el tema directamente, pero el resultado es el mismo. La salida sugiere que la operación es exitosa mientras se verifican las compensaciones con el comando describe o la depuración muestra que la compensación no se ha cambiado.

Cualquiera que tenga éxito con el restablecimiento de la compensación del consumidor dentro de corredores que no son cuidadores de animales.

Answer 1

Por defecto, --reset-offsets simplemente imprime el resultado de la operación. Para realizar la operación, debe agregar --execute a su comando:

kafka-consumer-groups.bat --bootstrap-server kafka-host:9092 --group
my-group --reset-offsets --to-earliest --all-topics --execute