在 Kafka Connect Struct Schema 上设置默认值

Question

我似乎在这里遗漏了一些明显的东西，或者 Kafka Connect 被严重破坏，这似乎不太可能。

我正在尝试在 Kafka Connect 的 struct 类型架构上设置默认值。我遇到的第一个问题是先有鸡还是先有蛋：要创建Struct，对于默认值，我需要传递其架构，但我只能在自己制作架构时设置默认值。这可以通过复制模式来克服，不使用默认值，或者通过在构建器上调用build() 来获取它的当前副本。

我想我以后可能会遇到optional 字段的问题，因为它在构建器上设置为null，在架构上设置为任何其他内容，并且没有办法将该标志强制设置为true 以外的任何内容。

但在那之前我失败了，因为架构构建器的类是SchemaBuilder，默认值的类是ConnectSchema，而且似乎没有办法那个。

那么，我错过了什么？还是这真的很糟糕？

Answer 1

我缺少的是，正如问题中所暗示的那样，SchemaBuilder 是 Schema，所以不是通过 builder.build() 来设置默认值，builder 是有问题的 SchemaBuilder，我只需通过builder。