缓存同步策略配置样例.md · 洪浩/l2cache

# 缓存同步策略配置

## 1、基于redis的发布订阅实现缓存同步
无需配置 `props` 。
```yaml
l2cache:
  config:
    # 缓存同步策略配置
    cacheSyncPolicy:
      # 策略类型 kafka / redis
      type: redis
      # 缓存更新时通知其他节点的topic名称
      topic: l2cache
```

## 2、基于kafka实现缓存同步
```yaml
l2cache:
  config:
    # 缓存同步策略配置
    cacheSyncPolicy:
      # 策略类型 kafka / redis
      type: kafka
      # 缓存更新时通知其他节点的topic名称
      topic: l2cache
      # 具体的属性配置，不同的类型配置各自的属性即可(自定义和原生的都可以)
      props:
        # kafka properties config
        bootstrap.servers: localhost:9092
        # 生产者id
        client.id: L2CacheProducer
        # 发送消息的确认机制
        acks: 1
        # key序列化处理器
        key.serializer: org.apache.kafka.common.serialization.StringSerializer
        # value序列化处理器
        value.serializer: org.apache.kafka.common.serialization.StringSerializer
        # 消费者groupid
        # 因为是缓存同步，所以必须让所有消费者都消费到相同的消息。采用动态生成一个id附加到配置的group.id上，实现每个consumer都是一个group，来实现发布订阅的模式。
        group.id: L2CacheConsumerGroup
        # 自动提交offset（默认true）
        enable.auto.commit: true
        # 自动提交间隔
        auto.commit.interval.ms: 1000
        # key反序列化处理器
        key.deserializer: org.apache.kafka.common.serialization.StringDeserializer
        # value反序列化处理器
        value.deserializer: org.apache.kafka.common.serialization.StringDeserializer
        # 设置消费的位置
        auto.offset.reset: latest
        # 设置一次最大拉取的消息条数（默认500）
        max.poll.records: 10
        # 设置poll最大时间间隔（默认3s）
        max.poll.interval.ms: 3000
```

洪浩/l2cache

简介

发行版

贡献者

近期动态

洪浩/l2cache .gitee-modal { width: 500px !important; }

简介

发行版

贡献者

近期动态

搜索帮助

洪浩/l2cache