カフカは消費者の結果をどのように取得するのか？

1年 ago
海斗, 葵
1 minute

Kafkaの消費者は、記録を取得することで結果を得ることができます。Java APIを使用してKafkaの消費者の結果を取得する手順は次のとおりです：

  1. Kafkaのコンシューマーの設定を作成します。
Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("group.id", "my-consumer-group");
props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
  1. Kafkaのコンシューマーインスタンスを作成する:
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
  1. 購読するテーマごとの支出：
consumer.subscribe(Collections.singletonList("my-topic"));
  1. 記録を繰り返し取得する。
while (true) {
    ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));
    for (ConsumerRecord<String, String> record : records) {
        System.out.println("Received record: " + record.value());
    }
}

上記のコードでは、poll()メソッドが記録を取得するために使用され、パラメータは最大待機時間です。ConsumerRecordsオブジェクトには、一括の消費記録が含まれており、それぞれのConsumerRecordオブジェクトを反復処理することで結果を取得できます。

注意：こちらのサンプルコードは簡略化されたバージョンですので、実際の使用にはさらなる設定と処理ロジックが必要となる場合があります。

bannerAds