1

docs/study/back/mq/Kafka.md

@@ -1,30 +1,56 @@
-### 简介
-
-kafka 最新定义为：分布式流式平台，而不是单纯的消息系统，更具有持久化、流处理的特点；主要处理两类应用：实时流数据管道和实时流应用程序。
-
-实时流数据管道：举个例子 Kafka+ELK 处理日志；
-实时流应用程序：举个例子 Kafka+报警模块 APP；
-持久化，可以作为存储系统，每个消费者对每个 topic 都有一个 offset 来记录上次消费的位置；
-
-### 常见使用场景
-
-1. 消息，可以媲美 ActiveMQ 和 RabbitMQ；
-2. 网站活动跟踪，数据>>Kafka>>ELK/Hbase/Hadoop；
-3. 度量，运营监控数据；
-4. 日志聚合，Kafka+ELK；
-5. 流处理，从 0.10 开始，Kafka Streams 是一个轻量级但功能强大的流处理库；
-
-### 常用命令
-
-```shell
-# 查看topic列表
-./kafka-topics.sh --list --bootstrap-server localhost:9092
-# 创建topic
-./kafka-topics.sh --create --bootstrap-server localhost:9092 --topic xxx
-# 创建生产者
-./kafka-console-producer.sh --bootstrap-server localhost:9092 --topic jiot.cloud
-# 创建消费者
-./kafka-console-consumer.sh --bootstrap-server localhost:9092 \
---topic jiot.cloud \
---from-beginning
-```
+### 简介
+
+kafka 最新定义为：分布式流式平台，而不是单纯的消息系统，更具有持久化、流处理的特点；主要处理两类应用：实时流数据管道和实时流应用程序。
+
+实时流数据管道：举个例子 Kafka+ELK 处理日志；
+实时流应用程序：举个例子 Kafka+报警模块 APP；
+持久化，可以作为存储系统，每个消费者对每个 topic 都有一个 offset 来记录上次消费的位置；
+
+### 常见使用场景
+
+1. 消息，可以媲美 ActiveMQ 和 RabbitMQ；
+2. 网站活动跟踪，数据>>Kafka>>ELK/Hbase/Hadoop；
+3. 度量，运营监控数据；
+4. 日志聚合，Kafka+ELK；
+5. 流处理，从 0.10 开始，Kafka Streams 是一个轻量级但功能强大的流处理库；
+
+### 常用命令
+
+参考 [quickstart](https://kafka.apache.org/quickstart)
+
+```shell
+# 进程+kafka启动方式
+tar -xzf kafka_2.13-3.7.0.tgz
+cd kafka_2.13-3.7.0
+#
+nohup bin/zookeeper-server-start.sh config/zookeeper.properties > /dev/null 2>&1 &
+#
+nohup bin/kafka-server-start.sh config/server.properties > /dev/null 2>&1 &
+#
+nohup ./chongqing.sh > /dev/null 2&>1 &
+```
+
+```shell
+#!/bin/sh
+echo -e "循环处理 ..."
+while [ 1 ]
+do
+echo '{"cloudID":"DcqcCcspgExtXcKp","orgID":1,"serviceCloudID":"HwygExtXcKp","serviceDirectoryID":"xc-kp_basicencryption_dataencryptioin_1","usedPercent":"30%","csID":6802687148295450000,"configNum":10,"serviceUsed":150,"serviceTotal":500,"serviceSpecification":50,"serviceCountUnit":"Mb/s"}' | ./bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic quickstart-events
+sleep 10s
+done
+```
+
+
+```shell
+# 查看topic列表
+./bin/kafka-topics.sh --list --bootstrap-server localhost:9092
+# 创建topic
+./bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --topic xxx
+# 创建生产者
+./bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic jiot.cloud
+./bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic quickstart-events
+# 创建消费者
+./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 \
+--topic quickstart-events \
+--from-beginning
+```

docs/study/devops/Linux运维-常用.md

@@ -328,6 +328,7 @@ sudo df -h
 # 实际的文件大小 如果和上面的不匹配，说明有删除文件但是空间未被释放
 sudo du -lh --max-depth=1 /
 # 进程占用文件，但是文件已被删除，文件所占磁盘空间未被释放；重启进程可以释放；
+# 存在这种情况的例子就是，启动进程 > 日志文件 2>&1 这个日志文件被删了之后不能够有效释放
 sudo lsof | grep deleted
 ```
 

docs/study/docker/docker-kafka.md

@@ -0,0 +1,13 @@
+### docker kafka
+
+```shell
+#
+docker pull apache/kafka:3.7.0
+#
+docker run -d \
+-p 9092:9092 \
+--privileged=true \
+-e TZ=Asia/Shanghai \
+--name kafka-study \
+apache/kafka:3.7.0
+```