小编a.l*_*.l.的帖子

我的应用程序有一些聚合/窗口操作,所以它有一些存储在其中的状态存储state.dir.AFAIK,它还将状态存储的更改日志写入代理,那么可以将Kafka Stream应用程序视为无状态POD吗？

我使用protobuf3来表示我们的数据，虽然我们需要hbase来存储数据，但看起来hbase依赖于protobuf2。

当我编写以下行来创建 hbase 表时

admin.createTable(desc);

然后我得到了一个异常：NoClassDefFoundError: com/google/protobuf/LiteralByteString

我尝试使用gradle的shadow插件将com.google.protobuf重新定位到shadow.google.com，然后它抛出类似的消息NoClassDefFoundError: shadow/google/protobuf/LiteralByteString。

我正在为我的应用程序使用 beego/orm。这里我有 2 个模型

type ModelA struct {
    Guid string `orm:"pk"`
    FiledA string
}

type ModelB struct {
    Guid string `orm:"pk"`
    FiledB string
}

我需要Save()为每个结构添加一个方法。通常，我可以创建一个Base结构并将其混合到ModelAand 中ModelB，但是 orm 不起作用。

有没有更好的解决办法？

编辑1：Save()在此处提供代码以使问题更清楚

func (this *ModelA) Save() error {
    o := orm.NewOrm()
    guid := guidlib.Generate()
    this.Guid = guid
    _, err := o.Insert(this)
    return err
}

func (this *ModelB) Save() error {
    o := orm.NewOrm()
    guid := guidlib.Generate()
    this.Guid = guid
    _, err := …