SpringでKafkaを統合する方法

2年 ago
芽依, 雨夜
1 minute

SpringはKafkaと連携する2つの方法を提供します。

  1. Spring Kafka の依存関係を導入する: プロジェクトの pom.xml ファイルに spring-kafka の依存関係を追加する。
<dependency>
    <groupId>org.springframework.kafka</groupId>
    <artifactId>spring-kafka</artifactId>
    <version>2.8.0</version>
</dependency>
  1. Kafkaの設定を作成する: Springの設定ファイルでKafkaの接続情報、消費者、プロデューサーの設定を構成する。
spring.kafka.bootstrap-servers=localhost:9092
spring.kafka.consumer.group-id=my-group
spring.kafka.consumer.auto-offset-reset=earliest
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer
  1. Kafka消費者を作成： `@KafkaListener` アノテーションを使用して Kafka 消費者を作成し、リッスンするトピックとメッセージを処理するためのメソッドを指定します。
@Component
public class KafkaConsumer {

    @KafkaListener(topics = "my-topic")
    public void receive(String message) {
        // 处理消息
        System.out.println("Received message: " + message);
    }
}
  1. KafkaTemplateを使用して指定されたトピックにメッセージを送信して、プロデューサーを作成します。
@Component
public class KafkaProducer {

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

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

以上の内容はSpringとKafkaを統合して使用する手法で、設定と注釈を使用することで、Kafkaのメッセージ送受信を簡単に利用できます。

bannerAds