Bu makale makine çevirisi ayna makalesidir, orijinal makaleye geçmek için lütfen buraya tıklayın.

Görünüm: 15810|Yanıt: 2

Windows Kafka HATASI Günlüğü temizlemede başarısız oldu__consumer_offsets

[Bağlantıyı kopyala]
Yayınlandı 6.07.2021 13:30:04 | | |
Eleştiri:

Kafka, JMX uzaktan izlemeyi yapılandırıyor
https://www.itsvse.com/thread-9968-1-1.html

Kafka yapılandırma parametrelerinin ayrıntılı açıklaması
https://www.itsvse.com/thread-9965-1-1.html

Kafka ofset ofsetini manuel olarak ayarlar
https://www.itsvse.com/thread-9641-1-1.html

.NET/C# mesaj kuyrukları için Kafka işlemleri [kaynak kodu ile]
https://www.itsvse.com/thread-9619-1-1.html


Windows Kafka hatası şöyledir:

[2021-07-06 09:05:54,809] HATA __consumer_offsets-42 için direksiyon C:\tmp\kafka-logs dosyasında IOException (kafka.server.LogDirFailureChannel) nedeniyle günlüğü temizlemek başarısız oldu
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] HATA [Log partition=__consumer_offsets-42, dir=C:\tmp\kafka-logs] Log dosyası C:\tmp\kafka-logs\__consumer_offsets-42\'ye karşılık gelen offset indeks dosyası bulunamadı 00000000000000000000.log, segment kurtarmak ve indeks dosyalarını yeniden oluşturmak gibi... (kafka.log.Günlük)

[2021-07-06 09:06:10,607] HATA /brokers/ids/0 adresinde geçici içerik oluştururken hata var, düğüm zaten var ve sahibin '72057597827809280' mevcut oturum '72057597827809313' ile eşleşmiyor (kafka.zk.KafkaZkClient$ CheckedEphemeral)
[2021-07-06 09:06:10,616] HATA [KafkaServer id=0] KafkaServer başlatılırken ölümcül hata. Kapanmaya hazırlanın (kafka.server.KafkaServer)
org.apache.zookeeper.KeeperException$NodeExistsException: KeeperErrorCode = NodeExists
        org.apache.zookeeper.KeeperException.create(KeeperException.java:126) adresinde
        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)
        Kafka'da. Kafka$.main(Kafka.scala:109)
        Kafka'da. Kafka.main(Kafka.scala)


Geçici çözüm

Zookeeper ve Kafka'yı durdurun, C:\tmp\kafka-logs\__consumer_offsets-42\ klasörünün altındaki tüm dosyaları silin.





Önceki:Windows altında, Java.exe ait olduğu programa bakın
Önümüzdeki:Linux Redis kaynak kodunun kurulumu ve dağıtımı
 Ev sahibi| Yayınlandı 6.07.2021 13:34:36 |
Kafka süreci zaman zaman kesiliyor.

1、HATA dir /tmp/kafka-logs'ta __consumer_offsets-30 için günlüğü temizlemek başarısız oldu (kafka.server.LogDirFailureChannel)

2. Linux, /tmp dizinindeki dosyaları düzenli olarak temizliyor ve benim kafka log dosya dizinim /tmp/kafka-logs dizinine yerleştiriliyor, bu yüzden düzenli olarak temizleniyor, bu yüzden kafka logları okumaya veya eklemeye çalışırken hata yapıyor.
grep log.dirs /opt/kafka_2.12-2.3.0/config/server.properties
/tmp/kafka-logs
3. Değiştir
log.dirs=/opt/kafka_2.12-2.3.0/kafka-logs/
4. Kafka'yı yeniden başlatın
5. Kafka log dizinini temizlik beyaz listesine ekleyin
/tmp dizininin centos7 altında temizlenmesi systemd hizmetinden sorumludur ve ilgili yapılandırma dosyaları /usr/lib/tmpfiles.d dizinindedir; tmp.conf yapılandırma dosyasını değiştirip kafka log dizinini ekliyoruz.
#防止删除kafka日志文件
X /tmp/kafka-logs

centos6'daki /tmp dizininin temizlenmesi, cron'un zamanlamasına dayanan tmpwatch ile sağlanır ve zamanlama dosyası /etc/cron.daily/tmpwatch olarak kullanılır
#防止删除kafka日志文件
X /tmp/kafka-logs
 Ev sahibi| Yayınlandı 12.07.2021 10:57:17 |
Kafka Windows sistemi bir süre çalıştıktan sonra kapanır
https://www.itsvse.com/thread-9984-1-1.html
Feragatname:
Code Farmer Network tarafından yayımlanan tüm yazılım, programlama materyalleri veya makaleler yalnızca öğrenme ve araştırma amaçları içindir; Yukarıdaki içerik ticari veya yasa dışı amaçlarla kullanılamaz, aksi takdirde kullanıcılar tüm sonuçları ödemelidir. Bu sitedeki bilgiler internetten alınmakta olup, telif hakkı anlaşmazlıklarının bu siteyle hiçbir ilgisi yoktur. Yukarıdaki içeriği indirmeden sonraki 24 saat içinde bilgisayarınızdan tamamen silmelisiniz. Programı beğendiyseniz, lütfen orijinal yazılımı destekleyin, kayıt satın alın ve daha iyi orijinal hizmetler alın. Herhangi bir ihlal olursa, lütfen bizimle e-posta yoluyla iletişime geçin.

Mail To:help@itsvse.com