Redis

RedisSinkConnector: From EventMesh to Redis topic queue

  1. start your Redis instance if needed and EventMesh Runtime.
  2. enable sinkConnector and check sink-config.yml.
  3. start your RedisConnectServer, it will subscribe to the topic defined in pubSubConfig.subject of EventMesh Runtime and send data to connectorConfig.topic in your Redis.
  4. send a message to EventMesh with the topic defined in pubSubConfig.subject and then you will receive the message in Redis.
  1. pubSubConfig:  
  2.   # default port 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.   # the topic in redis
  15.   topic: SinkTopic

RedisSourceConnector: From Redis topic queue to EventMesh

  1. start your Redis instance if needed and EventMesh Runtime.
  2. enable sourceConnector and check source-config.yml (Basically the same as sink-config.yml)
  3. start your RedisConnectServer, it will subscribe to the topic defined in connectorConfig.topic in your Redis and send data to pubSubConfig.subject of EventMesh Runtime.
  4. send a CloudEvent message to the topic in Redis, and you will receive the message in EventMesh.