Wow

中文

English

中文

English

外观

基础设施配置 ​

Kafka ​

属性类型默认值描述
wow.kafka.enabledBooleantrue启用 Kafka 集成
wow.kafka.bootstrap-serversList<String>（必填）Kafka bootstrap server 地址
wow.kafka.topic-prefixStringwow.Topic 名称前缀
wow.kafka.propertiesMap<String, String>{}额外的 Kafka 客户端属性
wow.kafka.producerMap<String, String>{}Kafka 生产者专属属性
wow.kafka.consumerMap<String, String>{}Kafka 消费者专属属性
wow.kafka.receiver.prefetch-batchesInteger1响应式接收端预取的 Kafka 轮询批次数
wow.kafka.receiver.max-deferred-commitsInteger1为保留偏移量间隙而缓存的乱序提交数
wow.kafka.receiver.retry-attemptsLong3每次连续接收失败的重试次数
wow.kafka.receiver.retry-backoffDuration10s接收端重试的最小退避时间
wow.kafka.receiver.decode-failure-strategyEnumFAIL无效记录策略：FAIL 或 ACKNOWLEDGE
yaml
wow:
  kafka:
    enabled: true
    bootstrap-servers:
      - localhost:9092
    topic-prefix: "wow."
    receiver:
      prefetch-batches: 1
      max-deferred-commits: 1
      retry-attempts: 3
      retry-backoff: 10s
      decode-failure-strategy: FAIL
    producer:
      acks: all
      retries: 3
    consumer:
      auto-offset-reset: earliest
      group-id: wow-consumer

MongoDB ​

属性类型默认值描述
wow.mongo.enabledBooleantrue启用 MongoDB 集成
wow.mongo.auto-init-schemaBooleantrue启动时自动初始化数据库 Schema
wow.mongo.event-stream-databaseString?null事件流使用的独立数据库（默认使用主数据库）
wow.mongo.snapshot-databaseString?null快照使用的独立数据库（默认使用主数据库）
wow.mongo.prepare-databaseString?nullPrepareKey 存储使用的独立数据库（默认使用主数据库）
wow.mongo.event-store-batch.enabledBooleanfalse使用 MongoDB insertMany 批量写入并发 EventStore 追加请求
wow.mongo.event-store-batch.max-sizeInt128同一集合单批最多包含的事件流数量
wow.mongo.event-store-batch.max-delayDuration1ms收集不足一批请求的最长等待时间
wow.mongo.event-store-batch.max-pending-appendsInt4096等待或正在写入的 append 最大接收数量；必须不小于 max-size
wow.mongo.event-store-batch.lane-countInt1串行写入 lane 数量；同一聚合的 append 始终进入同一 lane
wow.mongo.snapshot-store-batch.enabledBooleanfalse使用 MongoDB unordered bulkWrite 批量写入并发 SnapshotStore 保存请求
wow.mongo.snapshot-store-batch.max-sizeInt128同一集合单批最多包含的快照数量
wow.mongo.snapshot-store-batch.max-delayDuration1ms收集不足一批快照的最长等待时间
wow.mongo.snapshot-store-batch.max-pending-savesInt4096等待或正在写入的 save 最大接收数量；必须不小于 max-size
wow.mongo.snapshot-store-batch.lane-countInt1串行写入 lane 数量；同一聚合的 save 始终进入同一 lane
yaml
wow:
  mongo:
    enabled: true
    auto-init-schema: true
    event-stream-database: wow_events
    snapshot-database: wow_snapshots
    event-store-batch:
      enabled: true
      max-size: 128
      max-delay: 1ms
      max-pending-appends: 4096
      lane-count: 1
    snapshot-store-batch:
      enabled: true
      max-size: 128
      max-delay: 1ms
      max-pending-saves: 4096
      lane-count: 1

Redis ​

属性类型默认值描述
wow.redis.enabledBooleantrue启用 Redis 集成
wow.redis.message-bus.recovery.enabledBooleantrue恢复被遗留的 Redis Stream pending 消息
wow.redis.message-bus.recovery.min-idle-timeDuration5mpending 消息可恢复前的最小空闲时间
wow.redis.message-bus.recovery.intervalDuration30spending 消息扫描间隔
wow.redis.message-bus.recovery.batch-sizeLong100每页 XPENDING 最大记录数

Redis 连接通过 Spring Boot 标准的 spring.data.redis.* 属性进行配置。

yaml
spring:
  data:
    redis:
      host: localhost
      port: 6379

wow:
  redis:
    enabled: true
    message-bus:
      recovery:
        enabled: true
        min-idle-time: 5m
        interval: 30s
        batch-size: 100

Elasticsearch ​

属性类型默认值描述
wow.elasticsearch.enabledBooleantrue启用 Elasticsearch 集成
wow.elasticsearch.auto-init-templateBooleantrue在应用启动完成前初始化所需索引模板
wow.elasticsearch.event-store-batch.enabledBooleanfalse启用透明的 EventStore Bulk create 批处理
wow.elasticsearch.event-store-batch.max-sizeInt128单个 Bulk 请求最多包含的事件流数量
wow.elasticsearch.event-store-batch.max-delayDuration1ms收集不足一批事件的最长等待时间
wow.elasticsearch.event-store-batch.max-pending-appendsInt4096等待或正在写入的 append 最大接收数量；必须不小于 max-size
wow.elasticsearch.event-store-batch.lane-countInt1串行写入 lane 数量；同一聚合的 append 始终进入同一 lane
wow.elasticsearch.snapshot-store-batch.enabledBooleanfalse启用透明的 SnapshotStore Bulk update 批处理
wow.elasticsearch.snapshot-store-batch.max-sizeInt128单个 Bulk 请求最多包含的快照数量
wow.elasticsearch.snapshot-store-batch.max-delayDuration1ms收集不足一批快照的最长等待时间
wow.elasticsearch.snapshot-store-batch.max-pending-savesInt4096等待或正在写入的 save 最大接收数量；必须不小于 max-size
wow.elasticsearch.snapshot-store-batch.lane-countInt1串行写入 lane 数量；同一聚合的 save 始终进入同一 lane

Elasticsearch 连接通过 Spring Boot 标准的 spring.elasticsearch.* 属性进行配置。 开启自动初始化时，模板请求失败、无响应结果或未确认都会导致应用启动失败。 仅当索引模板由外部系统管理时，才应将 auto-init-template 设为 false。

yaml
spring:
  elasticsearch:
    uris: http://localhost:9200

wow:
  elasticsearch:
    enabled: true
    auto-init-template: true
    event-store-batch:
      enabled: true
      max-size: 128
      max-delay: 1ms
      max-pending-appends: 4096
      lane-count: 1
    snapshot-store-batch:
      enabled: true
      max-size: 128
      max-delay: 1ms
      max-pending-saves: 4096
      lane-count: 1

批处理默认关闭。EventStore 批处理使用 Bulk create；SnapshotStore 在 direct 和 batch 模式下都使用基于 _source.version 的原子保护更新，防止旧快照 （包括 legacy 文档）覆盖新快照。

WebFlux ​

属性类型默认值描述
wow.webflux.enabledBooleantrue启用 WebFlux 命令端点自动注册
wow.webflux.global-error.enabledBooleantrue启用全局错误处理
wow.webflux.batch.concurrencyInteger1批量命令请求的并发数
wow.webflux.batch.prefetchInteger1批量命令请求的预取数
wow.webflux.command.request.appender.agent.enabledBooleantrue将客户端 User-Agent 追加到命令请求上下文（设为 false 可禁用）
wow.webflux.command.request.appender.ip.enabledBooleantrue将客户端 IP 追加到命令请求上下文（设为 false 可禁用）
yaml
wow:
  webflux:
    enabled: true
    global-error:
      enabled: true
    batch:
      concurrency: 1
      prefetch: 1
    command:
      request:
        appender:
          agent:
            enabled: true
          ip:
            enabled: true

Released under the Apache 2.0 License.

Copyright © 2022-present Ahoo Wang