kafka2.8.1版本 搭建部署启动kafka
(一):搭建部署
在新发布的kafka2.8.0版本中,已经可以不启动zk就可以使用kafka了,
在config目录下多了一个kraft目录,在该目录中有一套新的配置文件,可以直接脱离ZooKeeper运行。
修改配置
到config下kraft目录中修改server.properties文件,单机的话主要是修改下面的配置
advertised.listeners=PLAINTEXT://localhost:9092
log.dirs=/tmp/kraft-combined-logs
(二):启动kafka
通过现在三行命令,即可开启一个单机的broker
./bin/kafka-storage.sh random-uuid
./bin/kafka-storage.sh format -t 1DViwWWpQf63N6bhJFAgzQ -c ./config/kraft/server.properties
./bin/kafka-server-start.sh ./config/kraft/server.properties
#后台启动
./bin/kafka-server-start.sh -daemon ./config/kraft/server.properties
创建topic
./bin/kafka-topics.sh --create --topic test --partitions 1 --replication-factor 1 --bootstrap-server localhost:9092
查看topic信息
./bin/kafka-topics.sh --describe --topic test --bootstrap-server localhost:9092
删除topic
./bin/kafka-topics.sh --delete --topic test --bootstrap-server localhost:9092
发送消息
./bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic test
消费消息
./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
################################################
OTHER:
bin/kafka-storage.sh random-uuid > uuid
bin/kafka-storage.sh format -t `cat uuid` -c config/kraft/server.properties
bin/kafka-server-start.sh -daemon config/kraft/server.properties
bin/kafka-topics.sh --create --topic foo --partitions 1 --replication-factor 1 --bootstrap-server localhost:9092
################################################