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