Kafka 如何告诉confluent cloud主题以编程方式使用特定模式?

5w9g7ksd  于 2023-01-29  发布在  Apache
关注(0)|答案(1)|浏览(126)

我知道如何使用confluent_Kafka AdminClient示例在Confluent Cloud上创建主题,但我不确定如何以编程方式设置主题的消息模式?为了澄清,我将想要使用的模式保存在本地的avro模式文件(.avsc)中

qacovj5a

qacovj5a1#

使用AdminClient创建主题,然后使用SchemaRegistryClient注册主题的架构。

相关问题