kafka安装

$ tar -xzvf kafka_2.13-3.2.1.tgz
$ cd kafka_2.13-3.2.1
$ cd config

broker.id=0
advertised.listeners=PLAINTEXT://127.0.0.1:9092
num.network.threads=3
num.io.threads=8
socket.send.buffer.bytes=102400
socket.receive.buffer.bytes=102400
socket.request.max.bytes=104857600
# 日志存储地址
log.dirs=/Users/ted/software/kafka_2.13-3.2.1/kafka-logs
num.partitions=1
num.recovery.threads.per.data.dir=1
offsets.topic.replication.factor=1
transaction.state.log.replication.factor=1
transaction.state.log.min.isr=1
log.retention.hours=168
log.segment.bytes=1073741824
log.retention.check.interval.ms=300000
# zookeeper地址
zookeeper.connect=127.0.0.1:2181
zookeeper.connection.timeout.ms=18000
group.initial.rebalance.delay.ms=0

# 启动
$ kafka-server-start.sh -daemon ./server.properties
# 创建topic
$ kafka-topics.sh --create --bootstrap-server localhost:9092 --topic first-topic --partitions 1 --replication-factor 1
# 查看topic list
$ kafka-topics.sh --bootstrap-server localhost:9092 --list
# 查看topic具体信息
$ kafka-topics.sh --bootstrap-server localhost:9092 --topic first-topic --describe
# 修改topic的partitions
$ kafka-topics.sh --bootstrap-server localhost:9092 --alter --topic first-topic --partitions 2
# 删除topic
$ kafka-topics.sh --bootstrap-server localhost:9092 --delete --topic first-topic
# produce 
$ kafka-console-producer.sh --topic first-topic --broker-list localhost:9092
# consume
$ kafka-console-consumer.sh --topic first-topic --bootstrap-server localhost:9092
$ kafka-console-consumer.sh --topic first-topic --bootstrap-server localhost:9092 --from-beginning