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 secara dinamis mengatur Topik atau GroupId Kafka
Melihat: 21474|Jawab: 0

[Sumber] Spring Boot secara dinamis mengatur Topik atau GroupId Kafka

[Salin tautan]
Diposting pada 14/11/2021 20.03.45 | | | |
Saat menyebarkan layanan mikro dalam kluster, jika kita ingin mengeluarkan perintah ke semua aplikasi, kita dapat berlangganan aplikasi ke topik Kafka, tetapi perlu dicatat bahwa groupID yang berbeda perlu diatur untuk topik yang sama untuk diterima oleh semua aplikasi.

Gunakan docker untuk membangun aplikasi Kafka dengan perintah berikut:

Catatan: Ganti 192.168.1.166 dengan alamat IP Anda yang sebenarnya

pom.xml Perkenalkan paket spring-kafka sebagai berikut:


Untuk menyesuaikan konfigurasi konsumen Kafka, buat file KafkaConsumer baru sebagai berikut:


Buat ConfigConsumer konsumen baru, yang memiliki konfigurasi default: topic:defaultTopic,groupid:defaultGroupId, dan kodenya adalah sebagai berikut:

application.properties untuk mengonfigurasi alamat Kafka:


Untuk memulai project, langganan aplikasi adalah konfigurasi default, sebagai berikut:



KafkaMessageListenerContainer mewarisi kelas abstrak AbstractMessageListenerContainer, dan metode createSimpleLoggingConsumerRebalanceListener menghasilkan partisi groupid dan topik konsumen.

2021-11-14 19:44:26.689 INFO 14256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : defaultGroupId: partisi yang ditetapkan: [defaultTopic-0]
Atur topik dan groupid secara dinamis, dan perintah project start adalah sebagai berikut:



Topik diatur ke a1 dan groupid adalah itsvse.com

2021-11-14 19:46:25.330 INFO 12256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : itsvse.com: partisi ditetapkan: [a1-0]
Spring mengesampingkan konfigurasi default di dalam paket jar
https://www.itsvse.com/thread-10129-1-1.html

(Akhir)





Mantan:Kueri lambat untuk pengoptimalan kinerja MySQL
Depan:Spring Boot Kafka dimulai ulang untuk membuang data lama

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