Chinaunix首页 | 论坛 | 博客
  • 博客访问: 7344921
  • 博文数量: 1763
  • 博客积分: 18684
  • 博客等级: 上将
  • 技术积分: 16217
  • 用 户 组: 普通用户
  • 注册时间: 2010-06-02 10:28
个人简介

啥也没写

文章分类

全部博文(1763)

文章存档

2023年(44)

2022年(39)

2021年(46)

2020年(43)

2019年(27)

2018年(44)

2017年(50)

2016年(47)

2015年(15)

2014年(21)

2013年(43)

2012年(143)

2011年(228)

2010年(263)

2009年(384)

2008年(246)

2007年(30)

2006年(38)

2005年(2)

2004年(1)

分类: 系统运维

2021-10-09 11:40:08

下载
wget archive.apache.org/dist/kafka/2.8.1/kafka_2.12-2.8.1.tgz
tar -zxvf kafka_2.12-2.8.1.tgz
mv kafka_2.12-2.8.1 /usr/local/

生成集群ID
#cd /usr/local/kafka_2.12-2.8.1
#./bin/kafka-storage.sh random-uuid
i7VXnngcSQiiIMb3PqXRnA

格式化存储目录
修改
40 listeners=PLAINTEXT://10.1.102.232:9092,CONTROLLER://:9093
41 inter.broker.listener.name=PLAINTEXT
46 advertised.listeners=PLAINTEXT://10.1.102.232:9092
74 log.dirs=/usr/local/kafka_2.12-2.8.1/tmp/kraft-combined-logs

你使用的多节点安装,你需要在每个节点上执行格式化命令,并确保每个节点使用的集群ID是相同的。
# ./bin/kafka-storage.sh format -t i7VXnngcSQiiIMb3PqXRnA -c config/kraft/server.properties
Formatting /usr/local/kafka_2.12-2.8.1/tmp/kraft-combined-logs

启动Kafka服务
 ./bin/kafka-server-start.sh ./config/kraft/server.properties


创建

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

# ./bin/kafka-topics.sh --create --topic test --partitions 1 --replication-factor 1 --bootstrap-server 10.1.102.232:9092
Created topic test.

查看
./bin/kafka-topics.sh --list --zookeeper localhost:2181
# ./bin/kafka-topics.sh --list --bootstrap-server 10.1.102.232:9092
test

# ./bin/kafka-console-producer.sh --broker-list 10.1.102.232:9092 --topic test
>

# ./bin/kafka-console-consumer.sh --bootstrap-server 10.1.102.232:9092 --topic test --from-beginning
ni hao ya

阅读(1425) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~