Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
¿Hay alguna forma de eliminar y luego volver a crear todos los temas de Kafka mostrados al ejecutar el siguiente comando desde la terminal Bash? kafka-topics –zookeeper localhost:2181
Actualmente estamos ejecutando una configuración de Kafka sin seguridad en AWS MSK (por lo que no tengo acceso a la mayoría de los archivos de configuración directamente y necesito utilizar kafka-cli) y estamos buscando formas de añadir protección. Configurar TLS y SASL es fácil, aunque como nuestro clúster de Kafka . . . Read more
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) . . . Read more