Partir de zéro : guide Springboot pour créer rapidement un environnement intégré Kafka

Présentation de Kafka intégré à Springboot

Apache Kafka est un service de streaming distribué qui vous permet de produire, consommer et stocker des données avec un débit extrêmement élevé. Il est largement utilisé pour créer une grande variété d'applications telles que l'agrégation de journaux, la collecte de métriques, la surveillance et les pipelines de données transactionnelles.

Springboot est un framework permettant de simplifier le développement d'applications Spring. Il fournit un câblage automatique et des conventions prêts à l'emploi pour intégrer facilement Kafka dans les applications Spring.

Créez l'environnement requis pour que Kafka intègre Springboot

1 Installez Apache Kafka

• Téléchargez la distribution Apache Kafka.
• Décompressez la distribution et démarrez le service Kafka.
• Vérifiez le journal du service Kafka pour vous assurer qu'il fonctionne correctement.

2. Installez Springboot

• Téléchargez la distribution Springboot.
• Extrayez la distribution et ajoutez-la au chemin de votre système.
• Créez une application Springboot.

Exemple de code

1. Créez une application Springboot

public class SpringbootKafkaApplication {

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

2. Ajoutez une dépendance Kafka

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

3. Configurez le producteur 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);
}

4. 6. Créez le service consommateur Kafka

@Bean
public ConcurrentKafkaListenerContainerFactory<String, String> kafkaListenerContainerFactory() {
    ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory<>();
    factory.setBrokerAddresses("127.0.0.1:9092");
    factory.setKeyDeserializer(new StringDeserializer());
    factory.setKeyDeserializer(new StringDeserializer());
    return factory;
}

Test

1. Utilisez ProducerService pour envoyer un message.
2. Vérifiez le journal du service Kafka pour vous assurer qu'il a reçu correctement les informations.
3. Vérifiez le journal de l'application Springboot pour vous assurer qu'il a correctement consommé les informations.
4. Résumé
5. Cet article montre comment intégrer Kafka dans une application Spring à l'aide de Springboot. Nous avons d'abord donné un aperçu de Kafka et Springboot, et expliqué comment créer l'environnement requis pour que Kafka intègre Springboot. Ensuite, nous fournissons un exemple détaillé d'application Springboot qui montre comment utiliser Springboot pour produire et consommer des informations Kafka.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!