通过kafka-avro-console-producer和confluent模式注册表使用RecordNameStrategy
通过kafka-avro-console-producer和confluent模式注册表使用RecordNameStrategy
提问于 2021-11-03 17:26:13
在尝试以下命令时使用kafka-avro-console-producer cli
kafka-avro-console-producer \
--broker-list <broker-list> \
--topic <topic> \
--property schema.registry.url=http://localhost:8081 \
--property value.schema.id=419
--property auto.register=false我有这个错误
org.apache.kafka.common.errors.SerializationException: Error retrieving Avro schema {...}
Caused by: io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException: Subject 'my-topic-name-value' not found.; error code: 40401因为我不是为我的主题使用TopicNameStrategy，而是RecordNameStrategy。我想指定它，我怎样才能找到允许设置cli使用的主题名称的属性？
注意:我，因为我找到了这个https://github.com/confluentinc/schema-registry/blob/a0a04628687a72ac6d01869d881a60fbde4177e7/avro-serializer/src/main/java/io/confluent/kafka/serializers/AbstractKafkaAvroSerDeConfig.java#L97，所以我已经尝试了以下方法，但没有太多成功
--property value.subject.name.strategy.default=io.confluent.kafka.serializers.subject.RecordNameStrategy回答 1
Stack Overflow用户
回答已采纳
发布于 2021-11-03 17:38:01
这很管用。
--property value.subject.name.strategy=io.confluent.kafka.serializers.subject.RecordNameStrategy页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/69829211
复制相关文章
相似问题
腾讯云开发者
