嗨,我正在使用 goka 在 go 中进行流处理。定义组时是否可以更改表主题名称?g := goka.DefineGroup(goka.Group("mygroup"), goka.Input(goka.Stream(*userProcessTopic), UserOpMsgCodec{}, msgCb), // here replace topic "mygroup-table" by "mygroup.data" for instance goka.Persist(MyCodec{}), )就像是 goka.PersistTo(MyCodec{}, "mytableName")
- 1 回答
- 0 关注
- 105 浏览
添加回答
举报
0/150
提交
取消