嗨，我正在使用 goka 在 go 中進(jìn)行流處理。定義組時(shí)是否可以更改表主題名稱？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 回答
守候你守候我
TA貢獻(xiàn)1802條經(jīng)驗(yàn) 獲得超10個(gè)贊
使用當(dāng)前版本 0.1.0 這是不可能的。所有組表都以組名加“-table”為后綴命名。在您的示例中，組表是“mygroup-table”。
- 1 回答
- 0 關(guān)注
- 136 瀏覽
添加回答
舉報(bào)
0/150
提交
取消