嗨，我在用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条答案
按热度按时间hwamh0ep1#
对于当前版本0.1.0，这是不可能的。所有组表都以后缀为“-table”的组名命名。在您的示例中，组表是“mygroup table”。
你可以在https://github.com/lovoo/goka/issues 如果你需要这样的功能。