如何通过Kafka-Redis-Sink连接器拆分Key将Kafka记录存入Redis？

需要配置Kafka-Redis-Sink连接器，按规则拆分Kafka记录的Key，将数据存储到Redis的哈希结构中，具体要求如下：

Kafka记录与预期Redis操作对应示例 #

<`key`> <`value`>                 ========&gt; `预期Redis操作` 
<User1|state1|id1> <data>     ========> redis=> hset "User1|state1"  "id1"  data 
<User1|state2|id2> <data>     ========> redis=> hset "User1|state2"  "id2"  data 
<User2|state1|id3> <data>     ========> redis=> hset "User2|state1"  "id3"  data 
<User2|state2|id4> <data>     ========> redis=> hset "User2|state2"  "id4"  data 

拆分后，Redis中会以用户|状态作为哈希表的Key，每个哈希表下存储该用户对应状态下的所有ID与数据的映射。执行HGETALL命令即可获取该哈希表的完整键值对：

Redis哈希表查询示例 #

HGETALL "User1|state1"

id1
data
id2
data

内容的提问来源于stack exchange，提问作者brij singh