Изменить название темы таблицы в Goka - PullRequest
Новая
       19

Изменить название темы таблицы в Goka

0 голосов
/ 27 декабря 2018

Привет, я использую 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 голосов
/ 14 января 2019

В текущей версии 0.1.0 это невозможно.Все таблицы групп именуются как имена групп с суффиксом «-table».В вашем примере групповой таблицей является «mygroup-table».

Вы можете открыть вопрос по номеру https://github.com/lovoo/goka/issues, если вам нужна такая функция.

...