Shulou(Shulou.com)06/01 Report--

This article is about how to build a kafka2.3 cluster. The editor thinks it is very practical, so share it with you as a reference and follow the editor to have a look.

Environment:

3 centos7.4

3 zookeeper3.4.14

Wget http://mirror.bit.edu.cn/apache/kafka/2.3.0/kafka_2.11-2.3.0.tgz

Decompress: tar-zxvf kafka_2.11-2.3.0.tgz

Enter the kafka directory, modify config/server.properties, find zookeeper.connect, and change the connection address of zk cluster to:

Zookeeper.connect=10.99.32.3:2181,10.99.32.31:2181,10.99.32.9:2181

Then modify broker.id=0 / / 1Pol 2. The id of each node must be different, otherwise the startup will report an error.

Start kafka:bin/kafka-server-start.sh-daemon config/server.properties

Startup error: org.apache.zookeeper.KeeperException$NodeExistsException: KeeperErrorCode = NodeExists: the directory is the same when writing to zk. The reason may be that the broker.id=1 in server.properties is duplicated.

After starting successfully, use jps to check the running, or use ps-aux | grep kafka. If there is a record, the operation is successful.

Create a topic:

Bin/kafka-topics.sh-- create-- zookeeper 10.99.32.3 replication-factor 2181-- partitions 1-- topic myTopic

Display topic information:

Bin/kafka-topics.sh-- describe-- zookeeper 10.99.32.3 zookeeper 2181-- topic myTopic

To add an Inode, you only need to add the configuration.

Thank you for reading! This is the end of the article on "how to build kafka2.3 clusters". 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!

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.