我知道如何使用confluent_Kafka AdminClient示例在Confluent Cloud上创建主题,但我不确定如何以编程方式设置主题的消息模式?为了澄清,我将想要使用的模式保存在本地的avro模式文件(.avsc)中
qacovj5a1#
使用AdminClient创建主题,然后使用SchemaRegistryClient注册主题的架构。
1条答案
按热度按时间qacovj5a1#
使用AdminClient创建主题,然后使用SchemaRegistryClient注册主题的架构。