安装
使用docker进行安装，很简单，中docker笔记中记录了，安装参考教程
基础配置
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
| <!--进入kafka容器-->
docker exec -it kafka bash
cd /opt/kafka/bin
<!--创建一个主题-->
kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 2 --topic kafka_demo
<!--查看主题-->
kafka-topics.sh --zookeeper zookeeper:2181 --list
<!--查看主题下的消息数量-->
kafka-run-class.sh kafka.tools.GetOffsetShell --topic firefly --time -1 --broker-list localhost:9092 --partitions 0
<!--删除主题-->
kafka-topics.sh --zookeeper zookeeper:2181 --delete --topic mykafka
<!--配置消息过期时间-->
cd /opt/kafka/bin
./kafka-configs.sh --zookeeper zookeeper:2181 --alter --entity-name telemetry_message --entity-type topics --add-config retention.ms=600000
<!--查看过期时间-->
./kafka-configs.sh --zookeeper zookeeper:2181 --describe --entity-name telemetry_message --entity-type topics
|
