Alpha 已经定义了一些 Akka 的参数,如果要在外部修改,可以通过 akkaConfig.{akka key} = value
方式配置
Alpha 单例模式
状态机持久化参数
akkaConfig: akka: persistence: journal: plugin: akka.persistence.journal.inmem leveldb.dir: actor/persistence/journal snapshot-store: plugin: akka.persistence.snapshot-store.local local.dir: actor/persistence/snapshots
Alpha 集群模式
状态机持久化参数
akkaConfig: akka: actor: provider: cluster persistence: at-least-once-delivery: redeliver-interval: 10s redelivery-burst-limit: 2000 journal: plugin: akka-persistence-redis.journal snapshot-store: plugin: akka-persistence-redis.snapshot akka-persistence-redis: redis: mode: "simple" host: "127.0.0.1" port: 6379 database: 0
Kafka 消费者参数
akkaConfig: akka: kafka: consumer: poll-interval: 50ms stop-timeout: 30s close-timeout: 20s commit-timeout: 15s commit-time-warning: 5s commit-refresh-interval: infinite wait-close-partition: 500ms position-timeout: 10s offset-for-times-timeout: 10s metadata-request-timeout: 10s eos-draining-check-interval: 30ms partition-handler-warning: 5s connection-checker.enable: false connection-checker.max-retries: 3 connection-checker.check-interval: 15s connection-checker.backoff-factor: 2.0