Redis

RedisSinkConnector：从 EventMesh 到 Redis 的消息队列

  1. 启动你的 Redis 实例和 EventMesh Runtime。
  2. 启用 sinkConnector 并检查 sink-config.yml。
  3. 启动你的 RedisConnectServer，它将订阅到 EventMesh Runtime 中 pubSubConfig.subject 中定义的主题，并将数据发送到 Redis 中的 connectorConfig.topic。
  4. 使用在 pubSubConfig.subject 中指定的 Topic，向 EventMesh 发送消息，然后你将在 Redis 中接收到该消息。
  1. pubSubConfig:
  2.   # 默认端口 10000
  3.   meshAddress: your.eventmesh.server:10000
  4.   subject: TopicTest  
  5.   idc: FT  
  6.   env: PRD
  7.   group: redisSink
  8.   appId: 5031
  9.   userName: redisSinkUser
  10.   passWord: redisPassWord
  11. connectorConfig:
  12.   connectorName: redisSink
  13.   server: redis://127.0.0.1:6379
  14.   # Redis 中的主题
  15.   topic: SinkTopic

RedisSourceConnector：从 Redis 的消息队列 到 EventMesh

  1. 启动你的 Redis 实例和 EventMesh Runtime。
  2. 启用 sourceConnector 并检查 source-config.yml（与 sink-config.yml 基本相同）。
  3. 启动你的 RedisConnectServer，它将订阅到 Redis 中的 connectorConfig.topic，并将数据发送到 EventMesh Runtime 中的 pubSubConfig.subject
  4. 向 Redis 的主题发送一个 CloudEvent 消息，然后你将在 EventMesh 中接收到该消息。