我使用的是卡夫卡风暴,卡夫卡发送/发射json字符串到风暴,在风暴中,我想根据json中的键/字段将负载分配给几个工人。怎么做?在我的例子中,它是json字符串中的物流字段。{groupid: 1234, userid: 145, comments:"I want to distribute all this group 1234 to one worker", size:50,type:"group json"}
{groupid: 1235, userid: 134, comments:"I want to distr