1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
| ./kafka-topic.sh --create --topic hello --bootstrap-server localhost:9092
./kafka-topic.sh --list --bootstrap-server localhost:9092
./kafka-topic.sh --delete --topic hello --bootstrap-server localhost:9092
./kafka-topic.sh --describe --topic hello --bootstrap-server localhost:9092
# alter 只能改参数,topic 名字改不了
./kafka-topic.sh --alter --topic hello --partition 5 --bootstrap-server localhost:9092
./kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
./kafka-console-consumer.sh --topic quickstart-events --from-begining --bootstrap-server localhost:9092
/etc/kafka/docker# docker cp f49748080656:/etc/kafka/docker/server.properties ./
# 配置
listeners: 0.0.0.0
advertised.listeners = PLAINTEXT://ip:9092
docker run --volume /etc/kafka/docker:/mnt/shared/config -p 9092:9092 apache/kafka
|