El broker no admite INCREMENTAL_ALTER_CONFIGS.
Cuando intento modificar un contenedor de Docker de tema de retención.ms de Kafka (para purgarlo), me encuentro con este error:
Error al ejecutar el comando de configuración con los argumentos ‘–bootstrap-server localhost:9092 –entity-type topics –alter –entity-name history.datastatechange –add-config retention.ms=1000’
java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.UnsupportedVersionException: El broker no admite INCREMENTAL_ALTER_CONFIGS
at java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396)
at java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2096)
at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:180)
at kafka.admin.ConfigCommand$.alterConfig(ConfigCommand.scala:360)
at kafka.admin.ConfigCommand$.processCommand(ConfigCommand.scala:327)
at kafka.admin.ConfigCommand$.main(ConfigCommand.scala:98)
at kafka.admin.ConfigCommand.main(ConfigCommand.scala)
Caused by: org.apache.kafka.common.errors.UnsupportedVersionException: El broker no admite INCREMENTAL_ALTER_CONFIGS
El comando que estoy ejecutando es:
kafka-configs –bootstrap-server localhost:9092 –entity-type topics –alter –entity-name history.datastatechange –add-config retention.ms=1000
No estoy seguro de qué es INCREMENTAL_ALTER_CONFIGS y cómo puedo agregarlo, ¿alguien puede compartir algo de sabiduría aquí?
davy.ai
De acuerdo con el mensaje de error, parece que el broker no admite INCREMENTAL_ALTER_CONFIGS.
INCREMENTAL_ALTER_CONFIGS es una función introducida en Apache Kafka versión 2.3.0 que te permite actualizar la configuración del tema sin afectar los valores de configuración existentes. Esto ayuda a prevenir la sobrescritura accidental de los valores de configuración que se establecieron manualmente.
Para resolver el problema, puedes intentar actualizar tu versión de Kafka a la versión 2.3.0 o posterior, y luego repetir el comando kafka-configs que intentabas ejecutar.
Alternativamente, puedes utilizar el comando
--alter-configen lugar de--add-config, que puede funcionar con versiones anteriores de Kafka.Por ejemplo, el comando se vería así:
Ten en cuenta que esto reemplazará completamente el valor existente de retention.ms con el nuevo valor de 1000, así que ten cuidado al usar este comando.