Produce and consume messages using authentication - Amazon Managed Streaming for Apache Kafka
Services or capabilities described in Amazon Web Services documentation might vary by Region. To see the differences applicable to the China Regions, see Getting Started with Amazon Web Services in China (PDF).

Produce and consume messages using authentication

This process describes how to produce and consume messages using authentication.

  1. Run the following command to create a topic. The file named client.properties is the one you created in the previous procedure.

    <path-to-your-kafka-installation>/bin/kafka-topics.sh --create --bootstrap-server BootstrapBroker-String --replication-factor 3 --partitions 1 --topic ExampleTopic --command-config client.properties

  2. Run the following command to start a console producer. The file named client.properties is the one you created in the previous procedure.

    <path-to-your-kafka-installation>/bin/kafka-console-producer.sh --bootstrap-server BootstrapBroker-String --topic ExampleTopic --producer.config client.properties

  3. In a new command window on your client machine, run the following command to start a console consumer.

    <path-to-your-kafka-installation>/bin/kafka-console-consumer.sh --bootstrap-server BootstrapBroker-String --topic ExampleTopic --consumer.config client.properties

  4. Type messages in the producer window and watch them appear in the consumer window.