2.6. クラスターの使用

この手順では、Kafka コンソールプロデューサーおよびコンシューマークライアントを起動し、これを使用して複数のメッセージを送受信する方法を説明します。

手順 1 つに新しいトピックが自動的に作成されます。トピックの自動作成 は、auto.create.topics.enable 設定プロパティーを使用して制御されます（デフォルトでは true に設定されます）。または、クラスターを使用する前にトピックを設定し、作成することができます。詳細は、「 トピック 」を参照してください。

前提条件

手順

  1. Kafka コンソールプロデューサーを起動し、メッセージを新しいトピックに送信するように設定します。 

    /opt/kafka/bin/kafka-console-producer.sh --broker-list <bootstrap-address> --topic <topic-name>

    以下に例を示します。 

    /opt/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic my-topic

  2. コンソールに複数のメッセージを入力します。Enter キーを押して、個別のメッセージを新しいトピックに送信します。 

    >message 1
>message 2
>message 3
>message 4

    Kafka が新しいトピックを自動的に作成すると、トピックが存在しないことを示す警告が表示されることがあります。 

    WARN Error while fetching metadata with correlation id 39 :
{4-3-16-topic1=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)

    さらにメッセージを送信した後も警告が表示されるはずです。

  3. 新しいターミナルウィンドウで、Kafka コンソールコンシューマーを起動し、新しいトピックの最初からメッセージを読み取るように設定します。 

    /opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server <bootstrap-address> --topic <topic-name> --from-beginning

    以下に例を示します。 

    /opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-topic --from-beginning

    受信メッセージがコンシューマーコンソールに表示されます。

  4. プロデューサーコンソールに切り替え、追加のメッセージを送信します。コンシューマーコンソールに表示されていることを確認します。
  5. Ctrl+C を押して、Kafka コンソールプロデューサーを停止し、コンシューマーを削除します。