Acest articol este un articol oglindă al traducerii automate, vă rugăm să faceți clic aici pentru a sări la articolul original.

Architect_Programmer_Code Rețeaua Agricolă»Arhitect › Programare › Chat tehnic › Windows Kafka ERROR Nu a reușit să curețe jurnalul pentru __con ...
Vedere: 15810|Răspunde: 2

Windows Kafka ERROR Nu a reușit să curețe jurnalul pentru __consumer_offsets

[Copiază linkul]
Postat pe 06.07.2021 13:30:04 | | |
Recenzie:

Kafka configurează monitorizarea la distanță JMX
https://www.itsvse.com/thread-9968-1-1.html

Explicație detaliată a parametrilor de configurație Kafka
https://www.itsvse.com/thread-9965-1-1.html

Kafka setează manual offset-ul
https://www.itsvse.com/thread-9641-1-1.html

Operații Kafka pentru cozi de mesaje .NET/C# [cu cod sursă]
https://www.itsvse.com/thread-9619-1-1.html


Eroarea Windows Kafka este următoarea:

[2021-07-06 09:05:54,809] EROARE: Eșecul de a curăța jurnalul pentru __consumer_offsets-42 în dir: C:\tmp\kafka-logs din cauza 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] EROARE: [Log partition=__consumer_offsets-42, dir=C:\tmp\kafka-logs] Nu am găsit fișierul index offset corespunzător fișierului log C:\tmp\kafka-logs\__consumer_offsets-42\ 00000000000000000000.log, recuperarea segmentelor și reconstruirea fișierelor index... (kafka.log.Jurnal)

[2021-07-06 09:06:10,607] EROARE Eroare în timpul creării efemerului la /brokers/ids/0, nodul există deja, iar proprietarul '72057597827809280' nu corespunde sesiunii curente '72057597827809313' (kafka.zk.KafkaZkClient$ CheckedEphemeral)
[2021-07-06 09:06:10,616] EROARE [KafkaServer id=0] Eroare fatală la pornirea KafkaServer. Pregătește-te de închidere (kafka.server.KafkaServer)
org.apache.zookeeper.KeeperException$NodeExistsException: KeeperErrorCode = NodeExists
        la 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)
        La Kafka. Kafka$.main(Kafka.scala:109)
        La Kafka. Kafka.main(Kafka.scala)


Soluție temporară

Oprește zookeeper și Kafka, șterge toate fișierele din folderul C:\tmp\kafka-logs\__consumer_offsets-42\.





Precedent:La Windows, vezi programul căruia îi aparține Java.exe
Următor:Instalarea și implementarea codului sursă Linux Redis

Postări conexe
 Proprietarul| Postat pe 06.07.2021 13:34:36 |
Procesul kafka se blochează din când în când.

1、ERROR Eșuat la curățarea jurnalului pentru __consumer_offsets-30 în dir/tmp/kafka-logs din cauza IOException (kafka.server.LogDirFailureChannel)

2. Linux va curăța fișierele din directorul /tmp în mod regulat, iar directorul meu de fișiere de log kafka este plasat în directorul /tmp/kafka-logs, ceea ce duce la curățarea lui regulată, astfel încât kafka va face o eroare când încearcă să citească sau să adauge loguri.
grep log.dirs /opt/kafka_2.12-2.3.0/config/server.properties
/tmp/kafka-logs
3. Modificare
log.dirs=/opt/kafka_2.12-2.3.0/kafka-logs/
4. Repornește kafka
5. Adaugă directorul de log kafka pe lista albă de curățare
Curățarea directorului /tmp sub centos7 este responsabilă pentru serviciul systemd, iar fișierele de configurare aferente se află în directorul /usr/lib/tmpfiles.d, modificăm fișierul de configurare tmp.conf și adăugăm directorul de log kafka în acesta.
#防止删除kafka日志文件
X /tmp/kafka-logs

Curățarea directorului /tmp din centos6 se realizează prin tmpwatch, care se bazează pe sincronizarea cronului, iar fișierul de programare este /etc/cron.daily/tmpwatch
#防止删除kafka日志文件
X /tmp/kafka-logs
 Proprietarul| Postat pe 12.07.2021 10:57:17 |
Sistemul Kafka Windows se va bloca după ce a funcționat o perioadă de timp
https://www.itsvse.com/thread-9984-1-1.html
Disclaimer:
Tot software-ul, materialele de programare sau articolele publicate de Code Farmer Network sunt destinate exclusiv scopurilor de învățare și cercetare; Conținutul de mai sus nu va fi folosit în scopuri comerciale sau ilegale, altfel utilizatorii vor suporta toate consecințele. Informațiile de pe acest site provin de pe Internet, iar disputele privind drepturile de autor nu au legătură cu acest site. Trebuie să ștergi complet conținutul de mai sus de pe calculatorul tău în termen de 24 de ore de la descărcare. Dacă îți place programul, te rugăm să susții software-ul autentic, să cumperi înregistrarea și să primești servicii autentice mai bune. Dacă există vreo încălcare, vă rugăm să ne contactați prin e-mail.
Mail To:help@itsvse.com