Este artículo es un artículo espejo de traducción automática, por favor haga clic aquí para saltar al artículo original.

Architect_Programmer_Code Red Agrícola»Arquitecto › Programación › Charla técnica › ERROR de Kafka de Windows: No se ha conseguido limpiar el registro de __con ...
Vista: 15810|Respuesta: 2

ERROR de Kafka en Windows: No se ha conseguido limpiar el registro de __consumer_offsets

[Copiar enlace]
Publicado en 6/7/2021 13:30:04 | | |
Revisión:

Kafka configura la monitorización remota de JMX
https://www.itsvse.com/thread-9968-1-1.html

Explicación detallada de los parámetros de configuración de Kafka
https://www.itsvse.com/thread-9965-1-1.html

Kafka ajusta manualmente el desplazamiento
https://www.itsvse.com/thread-9641-1-1.html

Operaciones de Kafka para colas de mensajes .NET/C# [con código fuente]
https://www.itsvse.com/thread-9619-1-1.html


El error de Kafka de Windows es el siguiente:

[2021-07-06 09:05:54,809] ERROR No se ha conseguido limpiar el log para __consumer_offsets-42 en el dir: C:\tmp\kafka-logs debido a IOException (kafka.server.LogDirFailureChannel)
java.nio.file.FileSystemException: C:\tmp\kafka-logs\__consumer_offsets-42\00000000000000000000.timeindex.cleaned -> C:\tmp\kafka-logs\__consumer_offsets-42\00000000000000000000.timeindex.swap:


[2021-07-06 09:06:06,460] ERROR [Log partition=__consumer_offsets-42, dir=C:\tmp\kafka-logs] No se pudo encontrar el archivo índice de offset correspondiente al archivo log C:\tmp\kafka-logs\__consumer_offsets-42\ 00000000000000000000.log, recuperar segmentos y reconstruir archivos índice... (kafka.log.Log)

[2021-07-06 09:06:10,607] ERROR Error Al crear efímero en /brokers/ids/0, el nodo ya existe y el propietario '72057597827809280' no coincide con la sesión actual '72057597827809313' (kafka.zk.KafkaZkClient$ RevisadoEfímero)
[2021-07-06 09:06:10,616] ERROR [KafkaServer id=0] Error fatal durante el inicio de KafkaServer. Prepárate para apagar (kafka.server.KafkaServer)
org.apache.zookeeper.KeeperException$NodeExistsException: KeeperErrorCode = NodeExists
        en org.apache.zookeeper.KeeperException.create(KeeperException.java:126)
        at kafka.zk.KafkaZkClient$CheckedEphemeral.getAfterNodeExists(KafkaZkClient.scala:1904)
        at kafka.zk.KafkaZkClient$CheckedEphemeral.create(KafkaZkClient.scala:1842)
        at kafka.zk.KafkaZkClient.checkedEphemeralCreate(KafkaZkClient.scala:1809)
        at kafka.zk.KafkaZkClient.registerBroker(KafkaZkClient.scala:96)
        at kafka.server.KafkaServer.startup(KafkaServer.scala:308)
        En Kafka. Kafka$.main(Kafka.scala:109)
        En Kafka. Kafka.main(Kafka.scala)


Solución temporal

Detén a zookeeper y Kafka, borra todos los archivos de la carpeta C:\tmp\kafka-logs\__consumer_offsets-42\.





Anterior:En Windows, consulta el programa al que pertenece Java.exe
Próximo:Instalación y despliegue del código fuente Redis de Linux

Publicaciones relacionadas
 Propietario| Publicado en 6/7/2021 13:34:36 |
El proceso kafka se queda colgado de vez en cuando.

1、ERROR No se ha limpiado el log para __consumer_offsets-30 en dir/tmp/kafka-logs debido a IOException (kafka.server.LogDirFailureChannel)

2. Linux limpia los archivos del directorio /tmp de forma regular, y mi directorio de archivos de registro de kafka se coloca en el directorio /tmp/kafka-logs, lo que hace que se limpie regularmente, así que kafka comete un error al intentar leer o añadir logs.
grep log.dirs /opt/kafka_2.12-2.3.0/config/server.properties
/tmp/kafka-logs
3. Modificar
log.dirs=/opt/kafka_2.12-2.3.0/kafka-logs/
4. Reiniciar Kafka
5. Añadir el directorio de registros de kafka a la lista blanca de limpieza
La limpieza del directorio /tmp bajo centos7 es responsable del servicio systemd, y sus archivos de configuración relacionados están en el directorio /usr/lib/tmpfiles.d; modificamos el archivo de configuración tmp.conf y añadimos el directorio de registro kafka.
#防止删除kafka日志文件
X /tmp/kafka-logs

La limpieza del directorio /tmp en centos6 se realiza mediante tmpwatch, que depende del tiempo de cron, y el archivo de programación es /etc/cron.daily/tmpwatch
#防止删除kafka日志文件
X /tmp/kafka-logs
 Propietario| Publicado en 12/7/2021 10:57:17 |
El sistema Kafka Windows se colga tras funcionar un tiempo
https://www.itsvse.com/thread-9984-1-1.html
Renuncia:
Todo el software, materiales de programación o artículos publicados por Code Farmer Network son únicamente para fines de aprendizaje e investigación; El contenido anterior no se utilizará con fines comerciales o ilegales; de lo contrario, los usuarios asumirán todas las consecuencias. La información de este sitio proviene de Internet, y las disputas de derechos de autor no tienen nada que ver con este sitio. Debes eliminar completamente el contenido anterior de tu ordenador en un plazo de 24 horas desde la descarga. Si te gusta el programa, por favor apoya el software genuino, compra el registro y obtén mejores servicios genuinos. Si hay alguna infracción, por favor contáctanos por correo electrónico.
Mail To:help@itsvse.com