您好,我正在使用 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")
最佳答案
在当前版本 0.1.0 中这是不可能的。所有组表都以组名加“-table”为后缀命名。在您的示例中,组表是“mygroup-table”。
您可以在 https://github.com/lovoo/goka/issues 打开一个问题如果你需要这样的功能。
关于go - 在 Goka 中更改表主题名称,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/53943063/