在 Goka 中更改表主题名称

Question

嗨，我正在使用 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")

Answer 1

使用当前版本 0.1.0 这是不可能的。所有组表都以组名加“-table”为后缀命名。在您的示例中，组表是“mygroup-table”。