如何在dotnet Confluent Kafka中定义自定义主题名策略

j0pj023g  于 2023-11-16  发布在  Apache
关注(0)|答案(1)|浏览(103)

目前Confluent Kafka dotnet支持三种主题名称策略:
1.主题名称
1.记录类型

  1. TopicRecord类型
    我想创建一个自定义主题策略,在其中可以生成具有自定义值的主题和模式。例如,
    主题:env.RecordTypeFullName
    请建议
jslywgbw

jslywgbw1#

正如你所看到的,没有一个值带有“env”前缀。因为值是一个枚举,所以没有简单的方法来覆盖它,它会抛出一个异常。
https://github.com/confluentinc/confluent-kafka-dotnet/blob/master/src/Confluent.SchemaRegistry/SubjectNameStrategy.cs#L97
在我看来,在模式中包含“env”前缀是一种反模式,因为dev/test/stage都应该尽可能接近“prod”。运行在“non-prod”中的注册服务器可能会在URL中编码env,但模式名称不应该。主题名称(即主题名称)可以。然后您可以使用TopicName / TopicRecord策略

相关问题