From bcf2f1fa88601a0d1376be50769a42e8c014e3cd Mon Sep 17 00:00:00 2001 From: xujun Date: Fri, 10 Jul 2026 16:40:07 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0kafka=E7=9A=84=E9=85=8D?= =?UTF-8?q?=E7=BD=AE=E6=96=87=E4=BB=B6demo?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../resources/application-boot-kafka.yaml | 20 +++++++++++++++++++ .../src/main/resources/application.yml | 1 + 2 files changed, 21 insertions(+) create mode 100644 xtools-app-standalone/src/main/resources/application-boot-kafka.yaml diff --git a/xtools-app-standalone/src/main/resources/application-boot-kafka.yaml b/xtools-app-standalone/src/main/resources/application-boot-kafka.yaml new file mode 100644 index 0000000..1409176 --- /dev/null +++ b/xtools-app-standalone/src/main/resources/application-boot-kafka.yaml @@ -0,0 +1,20 @@ +# Spring 配置 +spring: + # Kafka配置 + kafka: + # 指定Kafka集群的地址 + bootstrap-servers: ${KAFKA_HOST:127.0.0.1}:${KAFKA_PORT:9092} + consumer: + # 消费者组ID,用于消费者负载均衡和偏移量管理 + group-id: ${KAFKA_GROUP_ID:xtools} + # 当没有初始偏移量或偏移量丢失时,earliest:从最早的消息开始消费,latest:从最新的消息开始消费 + auto-offset-reset: ${KAFKA_AUTO_OFFSET_RESET:latest} + +xtools: + kafka: + # 分区数 + partitions: ${KAFKA_PARTITIONS:1} + # 副本数 + replicaCount: ${KAFKA_REPLICA_COUNT:1} + # 消息保留时长 + retentionMs: ${KAFKA_RETENTION_MS:604800000} \ No newline at end of file diff --git a/xtools-app-standalone/src/main/resources/application.yml b/xtools-app-standalone/src/main/resources/application.yml index a40bd01..d3128a2 100644 --- a/xtools-app-standalone/src/main/resources/application.yml +++ b/xtools-app-standalone/src/main/resources/application.yml @@ -17,6 +17,7 @@ spring: - boot-log - boot-mybatis-plus - boot-rabbitmq +# - boot-kafka - boot-redis - boot-xxl-job - boot-storage