Kafka から Java でデータを読み込むには

2年 ago
光, 明
1 minute

Kafkaからデータをプッシュするには、Kafka Javaクライアントを使用します。以下は、KafkaからJavaでデータを読み取る手順です。

  1. Mavenプロジェクトのpom.xmlファイルに、Kafkaクライアントライブラリの依存関係として以下を追加します。
<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-clients</artifactId>
    <version>2.8.1</version>
</dependency>
  1. KafkaのConsumerクラスを使用して、Kafkaコンシューマーインスタンスを作成します。Kafkaクラスターのホスト名、ポート番号、コンシューマーグループIDを指定する必要があります。
Properties properties = new Properties();
properties.put("bootstrap.servers", "localhost:9092"); // Kafka集群的地址和端口号
properties.put("group.id", "my-group"); // 消费者组ID

Consumer<String, String> consumer = new KafkaConsumer<>(properties);
  1. 購読する
consumer.subscribe(Arrays.asList("my-topic")); // 订阅名为"my-topic"的主题
  1. poll()
  2. ブロック
while (true) {
    ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));

    for (ConsumerRecord<String, String> record : records) {
        String key = record.key();
        String value = record.value();

        // 处理消息
        System.out.println("Received message: key = " + key + ", value = " + value);
    }
}
  1. 閉じる
consumer.close();

Java で Kafka からデータを読み取るための準備が整いました。ただし、上のコードは基本的な例のみを提供します。実際の使用では、具体的なニーズに応じて適切な修正と調整が必要になる場合があります。

bannerAds