乱读天书，不求甚解

周祎骏的个人云笔记

乱读天书，不求甚解

kafka 2.0 使用入门

2017-04-09 10:38:33 99 0 0

admin

> 这里介绍kafka的的使用方式

#详细配置
http://kafka.apache.org/documentation/#configuration 
***

#开启关闭
./bin/kafka-server-start.sh -daemon ./config/server.properties
./bin/kafka-server-stop.sh  #比起kill -9, 这种关闭方式会比较安全。
*这个脚本其实就是ps找到pid,然后kill -s TERM $PIDS,脚本写的不好，有时候抓不到进程号。*
***

#创建/修改/删除topic
**创建topic**
bin/kafka-topics.sh --zookeeper zk_host:port --create --topic topic名 --partitions 分片数 --replication-factor 备份数 --config x=y
**列出所有topic**
./bin/kafka-topics.sh --zookeeper localhost:2181  --list
**查看topic**
./bin/kafka-topics.sh --zookeeper localhost:2181  --describe
./bin/kafka-topics.sh --zookeeper localhost:2181  --describe --topic xxx
该命令会显示一个topic 的各个配置，replic 数量和对应的broker_id以及isr 所对应的broker_id
**修改topic**
bin/kafka-topics.sh --zookeeper zk_host:port --alter --topic topic名 --partitions 分片数 --config x=y
bin/kafka-topics.sh --zookeeper zk_host:port --alter --topic topic名 --partitions 分片数 --delete-config x
**删除topic**
bin/kafka-topics.sh --zookeeper zk_host:port --delete --topic topic名
需要配置文件中配置delete.topic.enable=true
***

##topic配置
```
retention.ms         数据保留多少毫秒
segment.index.bytes  数据保留多少字节
```
***

#读写数据
写：
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
读：
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

上一篇: kafka 1.0 安装

下一篇: kafka 3.0 水平扩展/迁移数据

文档导航