如何为融合模式注册表配置主题命名策略？

Question

我正在使用融合模式注册表和Avro，我想在一个Kafka主题中使用多个模式。

默认主题命名策略TopicNameStrategy不允许这样做，因为它将模式主题名称与主题名称耦合。显然可以覆盖它并将主题命名策略设置为RecordNameStrategy或TopicRecordNameStrategy。

不幸的是，留档不太清楚如何或在哪里可以覆盖主题命名策略。

本文档建议您在创建或修改主题时提供配置：

从Confluent Platform 5.5.0开始，命名策略与主题相关联。因此，您现在可以选择在每个主题的基础上为模式主题键和带有confluent.key.subject.name的值配置命名策略，而不是默认的命名策略。策略和合流。值。主题。名称。策略。

在ConFluent CLI中，使用--config选项创建或修改具有指定命名策略的主题。例如：

要创建使用RecordNameStrategy作为值的主题：

./bin/kafka-topics --create --bootstrap-server localhost:9092 \
--replication-factor 1 --partitions 1 --topic my-other-cool-topic \
--config confluent.value.schema.validation=true --config confluent.value.subject.name.strategy=io.confluent.kafka.serializers.subject.RecordNameStrategy

当我尝试此操作时，Kafka主题应用程序返回以下错误：

Error while executing topic command : Unknown topic config name: confluent.value.subject.name.strategy
[2020-10-31 10:17:00,947] ERROR org.apache.kafka.common.errors.InvalidConfigurationException: Unknown topic config name: confluent.value.subject.name.strategy
 (kafka.admin.TopicCommand$)

正如本文档所建议的，我还尝试在使用kafka-avro-concore-生产者通过属性value.subject.name.strategy向Kafka写入记录时配置主题名称策略。但是，控制台生产者忽略此属性并使用默认策略为主题创建一个新主题。

kafka-avro-console-producer \
    --broker-list kafka-broker-0.kafka-broker:9092 \
    --property schema.registry.url='http://kafka-schema-registry:8081' \
    --property value.schema='<MYSCHEMA>' \
    --property value.subject.name.strategy='io.confluent.kafka.serializers.subject.TopicRecordNameStrategy' \
    --topic mytopic

显然，过去有一种方法可以在代理本身上配置策略，但我也找不到任何文档说明如何做到这一点。

配置命名策略的正确方法是什么？它应该在哪里配置？在主题上，在主题生成器上（在本例中是kafka avro控制台生成器），还是在其他地方？

其他上下文：

• 我正在Docker中运行一切，使用图像confluentinc/cp kafka:6.0.0、confluentinc/cp模式注册表：6.0.0和confluentinc/cp zookeeper:6.0.0

Answer 1

kafka avro console producer尚不支持指定命名策略。您可以使用其他工具，如zoe：https://adevinta.github.io/zoe/advanced/avro/

它可以在生产者中定义为属性（key.subject.name.strategy和value.subject.name.strategy）。你可以从现有的策略中选择一种，也可以制定自己的策略。