嗨,我正在使用 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 關注
- 162 瀏覽
添加回答
舉報
0/150
提交
取消
