Bermula dari awal: Panduan Springboot untuk membina persekitaran bersepadu kafka dengan cepat

Gambaran keseluruhan Kafka bersepadu Springboot

Apache Kafka ialah perkhidmatan penstriman teragih yang membolehkan anda menghasilkan, menggunakan dan menyimpan data dengan daya pemprosesan yang sangat tinggi. Ia digunakan secara meluas untuk membina pelbagai jenis aplikasi seperti pengagregatan log, pengumpulan metrik, pemantauan dan saluran paip data transaksi.

Springboot ialah rangka kerja untuk memudahkan pembangunan aplikasi Spring. Ia menyediakan pendawaian automatik dan konvensyen luar biasa untuk menyepadukan Kafka dengan mudah ke dalam aplikasi Spring.

Bina persekitaran yang diperlukan untuk Kafka menyepadukan Springboot

1. Pasang Apache Kafka

• Muat turun pengedaran Apache Kafka.
• Buka zip pengedaran dan mulakan perkhidmatan Kafka.
• Lihat log perkhidmatan Kafka untuk memastikan ia berjalan dengan betul.

2. Pasang Springboot

• Muat turun pengedaran Springboot.
• Ekstrak pengedaran dan tambahkannya pada laluan sistem anda.
• Buat aplikasi Springboot.

Contoh Kod

1 Buat aplikasi Springboot

public class SpringbootKafkaApplication {

    public static void main(String[] args) {
        SpringApplication.run(SpringbootKafkaApplication.class, args);
    }
}

2 Tambah pergantungan Kafka

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-kafka</artifactId>
</dependency>

3

6. Buat perkhidmatan pengguna Kafka

@Bean
public ProducerFactory<String, String> senderFactory() {
    Map<String, Object> config = new LinkedHashMap<>();
    config.put(ProducerConfig.BOOTSTRAP_ certification_URL_setConfig, "kafka://127.0.0.1:9092");
    config.put(ProducerConfig.KEY_SERIALIZER_setClass_Config, StringDeserializer.class);
    config.put(ProducerConfig.KEY_SERIALIZER_setClass_Config, StringDeserializer.class);
    return new SimpleKafkaProducerFactory<>(config);
}

Ujian

Mulakan perkhidmatan Kafka.

Mulakan aplikasi Springboot.

Gunakan ProducerService untuk menghantar mesej.
1. Semak log perkhidmatan Kafka untuk memastikan ia telah menerima maklumat dengan betul.
2. Semak log aplikasi Springboot untuk memastikan ia telah menggunakan maklumat dengan betul.
4. Ringkasan
5. Artikel ini menunjukkan cara menyepadukan Kafka ke dalam aplikasi Spring menggunakan Springboot. Kami mula-mula memberikan gambaran keseluruhan Kafka dan Springboot, dan menerangkan cara membina persekitaran yang diperlukan untuk Kafka menyepadukan Springboot. Seterusnya, kami menyediakan contoh aplikasi Springboot terperinci yang menunjukkan cara menggunakan Springboot untuk menghasilkan dan menggunakan maklumat Kafka.

Atas ialah kandungan terperinci Bermula dari awal: Panduan Springboot untuk membina persekitaran bersepadu kafka dengan cepat. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!