Kafkaのデータを確認するには？
Kafkaのコマンドラインツールまたは、Kafkaクライアントライブラリを使用するプログラミング言語を使用して、Kafkaのデータを表示できます。以下に2つの方法の概要を示します。
Kafkaコマンドラインツールを使用する
データの表示や管理に使えるコマンドラインツールがいくつかKafkaに用意されています。その中で最もよく使われるのが`kafka-console-consumer`と
kafka-console-producer
kafka-console-consumer: Kafkaからメッセージを購読(読む)ために使用します。
Kafkaにメッセージをプロデュース（書き込み）するためのツール
kafka-console-consumerコマンドを使えば、Kafka内のデータをリアルタイムで確認できます。使用例は以下のとおりです。
浸透
kafka-console-consumer –bootstrap-server –topic <トピック名> [–from-beginning]
その住所は少なくとも４年以上は使われていなかった
パラメータの説明：
：Kafkaサーバのアドレスとポート番号
`<テーマ名>`: 消費するテーマ名
「–from-beginning」オプションは、指定されたトピックのすべてのメッセージの消費を先頭から開始します。
上記のコマンドを実行すると、リアルタイムでKafkaのデータを確認できます。
2. Kafkaクライアントを使ってプログラミングする方法
Kafkaのデータにプログラミング言語からアクセスするには、Kafkaのクライアントライブラリを利用します。Kafkaは以下のような複数のプログラミング言語に公式クライアントライブラリを提供しています。
Java、Python、Goなどなど
Javaの例では、`kafka-clients`ライブラリを使用してKafkaからメッセージをコンスーマするJavaプログラムを作成できます。以下にサンプルコードを示します。
この文は生粋の日本語で言い換えてください。オプションは1つだけです。“`
import org.apache.kafka.clients.consumer.*;
import java.util.*; // Javaユーティリティパッケージをインポート
import java.util.concurrent.TimeUnit;
public クラス KafkaConsumerExample
public静的void main(String[] args) {
Properties props = new Properties();
props.put(“bootstrap.servers”, “”);
プロパティ.put(“グループ.id”, “<コンシューマーグループID>”);
props.put(“key.deserializer”, “org.apache.kafka.common.serialization.StringDeserializer”)
props.put(“value.deserializer”, “org.apache.kafka.common.serialization.StringDeserializer”);
KafkaConsumer consumer = new KafkaConsumer<>(props);
consumer.subscribe(Collections.singletonList(“topicName”));
はじめます
while(true){
ConsumerRecords records = consumer.poll(Duration.ofMillis(100));
ConsumerRecord record : records の各要素に対して {
System.out.println(レコード._value);
この本は現実的ではない。
翻訳はネイティブレベルでお願い
catch (Exception e) { }
e.printStackTrace();
ついに
consumer.クローズ();
この部屋は、私たちの喜びの源であり、私たちの生活の中心です。
人は嘘をつくのが上手です。
もう型にはまらない標準化について考える時期が到来しました。
大いに後悔する事になり、動揺しないようにする事が難しい。
上記に記載されたコードは、指定されたトピックを購読し、ループによって絶えずメッセージを取得して表示するKafkaコンシューマーを作成します。
“、`<コンシュマーグループID>`、`<トピック名>` を実際の値に置き換えてこのプログラムを実行すると、Kafka 内で消費および表示できます。
ネイティブな日本語に言い換えると、次のような表現になります。
* 本来のデータ
状況に応じて、Kafka 内のデータを参照する適切な方法を選択する必要があります。
