Artikel ini adalah artikel cermin dari terjemahan mesin, silakan klik di sini untuk melompat ke artikel aslinya.

Jaringan Pertanian Architect_Programmer_Code»Arsitek › Pemrograman › Jawa › Spring Boot Kafka dimulai ulang untuk membuang data lama
Melihat: 21274|Jawab: 1

[Sumber] Spring Boot Kafka dimulai ulang untuk membuang data lama

[Salin tautan]
Dipaparkan pada 2021-11-14 21:42:26 | | |
Persyaratan: Saat aplikasi spring boot diluncurkan, beberapa informasi konfigurasi akan dibaca dari database atau cache, dan Kafka akan digunakan untuk berlangganan perubahan informasi konfigurasi. Karena aplikasi dimulai dengan informasi konfigurasi terbaru, pesan tentang pembaruan konfigurasi Kafka historis tidak akan ada artinya, dan jika Anda menggunakan pesan historis, Anda akan mengalami masalah.

Setelah aplikasi Spring Boot dimulai ulang, ada pertanyaan tentang cara membuang data lama tentang suatu topikPesan Kafka untuk sejarah topik itu tidak diterimaIni? Faktanya, masalah ini dapat diselesaikan dengan mengatur offset awal, yang memungkinkan pelanggan untuk mengatur offset topik ke posisi terakhir sebelum berlangganan pesan.

Bahkan jika spring.kafka.consumer.auto-offset-reset diatur ke terbaru, konsumen akan membaca pesan dari bit bendera tempat terakhir diakui telah menerima pesan, yang akan menyebabkan konsumen membaca sejumlah besar pesan setelah memulai ulang jika produsen mengirim pesan dalam jumlah besar saat aplikasi ditutup.

Konsumen mencari offset tertentu selama inisialisasi, dengan kode berikut:

(Akhir)





Mantan:Spring Boot secara dinamis mengatur Topik atau GroupId Kafka
Depan:Linux melihat output log dari layanan Systemd

Pos terkait
 Tuan tanah| Dipaparkan pada 2021-11-15 10:37:05 |
Spring Boot secara dinamis mengatur Topik atau GroupId Kafka
https://www.itsvse.com/thread-10152-1-1.html

Di bawah CentOS 7, Kafka sering menutup solusi
https://www.itsvse.com/thread-10090-1-1.html

Nilai auto.offset.reset Kafka dijelaskan secara rinci
https://www.itsvse.com/thread-10017-1-1.html

Sistem Kafka Windows akan menutup telepon setelah berjalan untuk jangka waktu tertentu
https://www.itsvse.com/thread-9984-1-1.html

KESALAHAN Windows Kafka Gagal membersihkan log untuk __consumer_offsets
https://www.itsvse.com/thread-9980-1-1.html

Kafka mengonfigurasi pemantauan jarak jauh JMX
https://www.itsvse.com/thread-9968-1-1.html

Penjelasan rinci tentang parameter konfigurasi Kafka
https://www.itsvse.com/thread-9965-1-1.html

Kafka secara manual mengatur offset offset
https://www.itsvse.com/thread-9641-1-1.html

Operasi Kafka untuk antrean pesan .NET/C# [dengan kode sumber]
https://www.itsvse.com/thread-9619-1-1.html
Sanggahan:
Semua perangkat lunak, materi pemrograman, atau artikel yang diterbitkan oleh Code Farmer Network hanya untuk tujuan pembelajaran dan penelitian; Konten di atas tidak boleh digunakan untuk tujuan komersial atau ilegal, jika tidak, pengguna akan menanggung semua konsekuensi. Informasi di situs ini berasal dari Internet, dan sengketa hak cipta tidak ada hubungannya dengan situs ini. Anda harus sepenuhnya menghapus konten di atas dari komputer Anda dalam waktu 24 jam setelah pengunduhan. Jika Anda menyukai program ini, harap dukung perangkat lunak asli, pembelian pendaftaran, dan dapatkan layanan asli yang lebih baik. Jika ada pelanggaran, silakan hubungi kami melalui email.
Mail To:help@itsvse.com