feat: 增加Kafka中间件

apps/kafka/3.6.0/data.yml

@@ -0,0 +1,16 @@
+additionalProperties:
+ formFields:
+ - default: 9092
+ envKey: KAFKA_PORT
+ labelEn: Port
+ labelZh: TCP 端口
+ required: true
+ rule: paramPort
+ type: number
+ - default: '127.0.0.1'
+ envKey: KAFKA_HOST
+ labelEn: Host
+ labelZh: Host/IP
+ required: true
+ rule: paramCommon
+ type: text

apps/kafka/3.6.0/docker-compose.yml

@@ -0,0 +1,30 @@
+version: '3'
+services:
+ kafka:
+ container_name: ${CONTAINER_NAME}
+ restart: always
+ environment:
+ ALLOW_PLAINTEXT_LISTENER: 'yes'
+ KAFKA_CFG_LOG_RETENTION_MS: 60000
+ KAFKA_CFG_MAX_REQUEST_SIZE: 524288000
+ KAFKA_CFG_MESSAGE_MAX_BYTES: 524288000
+ KAFKA_CFG_REPLICA_FETCH_MAX_BYTES: 524288000
+ KAFKA_CFG_FETCH_MESSAGE_MAX_BYTES: 524288000
+ KAFKA_CFG_PARTITION_FETCH_BYTES: 524288000
+ KAFKA_CFG_NODE_ID: 0
+ KAFKA_CFG_PROCESS_ROLES: controller,broker
+ KAFKA_CFG_LISTENERS: PLAINTEXT://:9092,CONTROLLER://:9093
+ KAFKA_CFG_ADVERTISED_LISTENERS: PLAINTEXT://${KAFKA_HOST}:${KAFKA_PORT}
+ KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP: CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT
+ KAFKA_CFG_CONTROLLER_QUORUM_VOTERS: 0@127.0.0.1:9093
+ KAFKA_CFG_CONTROLLER_LISTENER_NAMES: CONTROLLER
+ networks:
+ - 1panel-network
+ ports:
+ - "${KAFKA_PORT}:9092"
+ image: bitnami/kafka:3.6.0
+ labels:
+ createdBy: "Apps"
+networks: 
+ 1panel-network: 
+ external: true

apps/kafka/README.md

@@ -0,0 +1,9 @@
+# Kafka
+
+Kafka 一个分布式流处理平台
+
+## 主要功能：
+
+- 它能够让应用发布或预订数据或事件流。
+- 它能够以可容错的持久方式准确地存储记录（即，按照记录的出现顺序）。
+- 它能够实时处理记录（一出现便处理）。

apps/kafka/data.yml

@@ -0,0 +1,19 @@
+name: Kafka
+tags:
+ - 中间件
+title: Kafka 一个分布式流处理平台
+type: 中间件
+description: Kafka 是一个分布式流处理平台
+additionalProperties:
+ key: kafka
+ name: Kafka
+ tags:
+ - Middleware
+ shortDescZh: Apache Kafka 是一种分布式数据存储，经过优化以实时提取和处理流数据。流数据是指由数千个数据源持续生成的数据，通常可同时发送数据记录。流平台需要处理这些持续流入的数据，按照顺序逐步处理。
+ shortDescEn: Apache Kafka is a distributed data store optimized for ingesting and processing streaming data in real-time. Streaming data is data that is continuously generated by thousands of data sources, which typically send the data records in simultaneously. A streaming platform needs to handle this constant influx of data, and process the data sequentially and incrementally.
+ type: tool
+ crossVersionUpdate: false
+ limit: 0
+ website: https://kafka.apache.org/
+ github: https://github.com/apache/kafka
+ document: https://kafka.apache.org/documentation/