jeff-zou/flink-connector-redis

Flink CDC同步MySQL数据到Redis时，Redis不能同步删除数据

hziling opened this issue · 5 comments

hziling commented

Redis 表配置为

***
'command'='SET',
'value.data.structure' = 'column'

MySQL写入、更新数据的时候Redis数据会同步，但是MySQL删除数据的时候Redis数据没有同步删除

hziling commented

是不是可以增加一种模式，可以同时支持SET、DEL？

jeff-zou commented

我试验一下先

jeff-zou commented

没问题，这两周会发一个新版本支持

awakelee commented

Is there any progress? @jeff-zou

jeff-zou commented

has been updated: https://github.com/jeff-zou/flink-connector-redis/releases/tag/1.3.1

Please use dependency like this:
<dependency> <groupId>io.github.jeff-zou</groupId> <artifactId>flink-connector-redis</artifactId> <version>1.3.1</version> </dependency>

CDC时支持类型

CDC插入及更新 CDC删除时响应操作
set del
hset hdel
rpush lpush 不响应
incrBy incrByFloat decrBy hincrBy hincryByFloat zincrby 写入相对值，如:incrby 2 -> incryby -2
sadd zadd srem zrem
pfadd(hyperloglog) 不响应
publish 不响应
zrem srem 不响应
del hdel 不响应
注：cdc更新操作与插入效果相同