ゼロから始める: Kafka 統合環境を迅速に構築するための Springboot ガイド

Springboot Integrated Kafka の概要

Apache Kafka は、非常に高いスループットでデータを生成、消費、保存できる分散ストリーミング サービスです。これは、ログ集約、メトリック収集、監視、トランザクション データ パイプラインなどのさまざまなアプリケーションを構築するために広く使用されています。

Springboot は、Spring アプリケーション開発を簡素化するためのフレームワークです。これは、Kafka を Spring アプリケーションに簡単に統合するための、すぐに使用できる自動配線と規約を提供します。

Kafka が Springboot を統合するために必要な環境を構築する

1. Apache Kafka をインストールする

• Apache Kafka ディストリビューションをダウンロードします。
• ディストリビューションを解凍し、Kafka サービスを開始します。
• Kafka サービス ログをチェックして、正常に実行されていることを確認します。

2. Springboot のインストール

• Springboot ディストリビューションをダウンロードします。
• ディストリビューションを抽出し、システムのパスに追加します。
• Springboot アプリケーションを作成します。

コード例

1. Springboot アプリケーションの作成

public class SpringbootKafkaApplication {

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

2. Kafka 依存関係の追加

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

3. 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. 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;
}

5. Kafka プロデューサー サービスの作成

@Service
public class ProducerService {

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

    public void sendMessage(String message) {
        kafkaTemplate.send("test-kafka", message);
    }
}

6. Kafka コンシューマー サービスの作成

@Service
public class ReceiverService {

    @KafkaListener(topics = "test-kafka", id = "kafka-consumer-1")
    public void receiveMessage(String message) {
        System.out.println("Message received: " + message);
    }
}

Test

1. Kafka サービスを開始します。
2. Springboot アプリケーションを開始します。
3. ProducerService を使用してメッセージを送信します。
4. Kafka サービス ログをチェックして、情報が正しく受信されていることを確認します。
5. Springboot アプリケーション ログをチェックして、情報が正しく消費されていることを確認します。

概要

この記事では、Springboot を使用して Kafka を Spring アプリケーションに統合する方法を説明します。まずKafkaとSpringbootの概要を説明し、KafkaがSpringbootを統合するために必要な環境の構築方法について説明しました。次に、Springboot を使用して Kafka 情報を生成および消費する方法を示す、詳細な Springboot アプリケーションの例を示します。

以上がゼロから始める: Kafka 統合環境を迅速に構築するための Springboot ガイドの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。