How to install and implement stand-alone testing in kafka

This article is about how to install and implement stand-alone testing of kafka. The editor thinks it is very practical, so share it with you as a reference and follow the editor to have a look.

1.3 Quick Start

This tutorial assumes you are starting fresh and have no existing Kafka or ZooKeeper data.

Step 1: Download the code

Download the 0.10.0.0 release and un-tar it.

> tar-xzf kafka_2.11-0.10.0.0.tgz > cd kafka_2.11-0.10.0.0Step 2: Start the server

Kafka uses ZooKeeper so you need to first start a ZooKeeper server if you don't already have one. You can use the convenience script packaged with kafka to get a quick-and-dirty single-node ZooKeeper instance.

> bin/zookeeper-server-start.sh config/zookeeper.properties [2013-04-22 15 config/zookeeper.properties 01 config/zookeeper.properties 37495] INFO Reading configuration from: (org.apache.zookeeper.server.quorum.QuorumPeerConfig).

Now start the Kafka server:

> bin/kafka-server-start.sh config/server.properties [2013-04-22 15 kafka.utils.VerifiableProperties 01purl 47028] INFO Verifying properties (kafka.utils.VerifiableProperties) [2013-04-22 15 kafka.utils.VerifiableProperties 01purl 47051] INFO Property socket.send.buffer.bytes is overridden to 1048576 (kafka.utils.VerifiableProperties)... Step 3: Create a topic

Let's create a topic named "test" with a single partition and only one replica:

> bin/kafka-topics.sh-create-zookeeper localhost:2181-replication-factor 1-partitions 1-topic test

We can now see that topic if we run the list topic command:

> bin/kafka-topics.sh-list-zookeeper localhost:2181test

Alternatively, instead of manually creating topics you can also configure your brokers to auto-create topics when a non-existent topic is published to.

Step 4: Send some messages

Kafka comes with a command line client that will take input from a file or from standard input and send it out as messages to the Kafka cluster. By default each line will be sent as a separate message.

Run the producer and then type a few messages into the console to send to the server.

> bin/kafka-console-producer.sh-- broker-list localhost:9092-- topic testThis is a messageThis is another messageStep 5: Start a consumer

Kafka also has a command line consumer that will dump out messages to standard output.

> bin/kafka-console-consumer.sh-zookeeper localhost:2181-topic test-from-beginningThis is a messageThis is another message

It's easy to use.

Production message

Real-time consumption

Thank you for reading! This is the end of the article on "how to install and implement stand-alone testing of kafka". I hope the above content can be of some help to you, so that you can learn more knowledge. if you think the article is good, you can share it for more people to see!