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

Architect_Programmer_Code Tarım Ağı»Mimar › Programlama › Java › Spring Boot Kafka eski verileri atmak için yeniden başlatıyor
Görünüm: 21274|Yanıt: 1

[Kaynak] Spring Boot Kafka eski verileri atmak için yeniden başlatıyor

[Bağlantıyı kopyala]
2021-11-14 tarihinde 21:42:26 tarihinde yayınlandı | | |
Gereksinimler: Bahar önyükleme uygulaması başlatıldığında, veritabanından veya önbellekten bazı yapılandırma bilgileri okunur ve Kafka yapılandırma bilgisi değişikliklerine abone olmak için kullanılır. Uygulama en son yapılandırma bilgileriyle başladığı için, tarihsel Kafka yapılandırma güncellemeleriyle ilgili mesajlar anlamsız olur ve geçmiş mesajları kullanırsanız sorun yaşarsınız.

Spring Boot uygulaması yeniden başladıktan sonra, bir konudaki eski verilerin nasıl atılacağı sorusu ortaya çıkarBu konunun tarihine dair Kafka mesajları alınmadıBu? Aslında, bu sorun başlangıç ofseti ayarlanarak çözülebilir; bu da abonenin mesaja abone olmadan önce konunun ofsetini son konuma ayarlamasına olanak tanır.

spring.kafka.consumer.auto-offset-reset en son olarak ayarlanmış olsa bile, tüketici mesajı en son alındığı onaylanan bayrak bitinden okur; bu da üretici uygulama kapalıyken çok sayıda mesaj gönderirse tüketicinin yeniden başlattıktan sonra çok sayıda mesaj okumasına neden olur.

Tüketici, başlatma sırasında belirli bir ofset arar, aşağıdaki kodla:

(Son)





Önceki:Spring Boot, Kafka'nın Topic veya GroupId'sini dinamik olarak ayarlar
Önümüzdeki:Linux, Systemd servisinin log çıktısına bakıyor

İlgili Yazılar
 Ev sahibi| 2021-11-15 tarihinde 10:37:05 tarihinde yayınlandı |
Spring Boot, Kafka'nın Topic veya GroupId'sini dinamik olarak ayarlar
https://www.itsvse.com/thread-10152-1-1.html

CentOS 7 altında ise Kafka genellikle çözümleri kapatıyor
https://www.itsvse.com/thread-10090-1-1.html

Kafka'nın auto.offset.reset değeri ayrıntılı olarak açıklanmıştır
https://www.itsvse.com/thread-10017-1-1.html

Kafka Windows sistemi bir süre çalıştıktan sonra kapanır
https://www.itsvse.com/thread-9984-1-1.html

Windows Kafka HATASI Günlüğü temizlemede başarısız oldu__consumer_offsets
https://www.itsvse.com/thread-9980-1-1.html

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
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