在confluent Kafka中更改模式名称策略
在Confluent Kafka中更改模式名称策略是通过修改Kafka的配置文件来实现的。具体步骤如下：
- 打开Kafka的配置文件，通常位于
/etc/kafka/server.properties。 - 在配置文件中找到
kafkastore.topic参数，该参数用于指定存储Kafka模式的主题名称，默认为_schemas。 - 修改
kafkastore.topic参数的值为新的模式名称，确保新名称在Kafka集群中唯一。 - 保存配置文件并重启Kafka服务，使配置生效。
更改模式名称策略可以帮助组织更好地管理和组织模式，以适应不同的业务需求和命名约定。
Confluent提供了一系列与Kafka相关的产品和服务，以下是一些推荐的腾讯云相关产品和产品介绍链接地址：
- 腾讯云消息队列 CKafka：腾讯云提供的高可用、高可靠、高性能的分布式消息队列服务，基于Apache Kafka构建。
- 腾讯云云原生数据库 TDSQL-C：腾讯云提供的云原生分布式数据库，支持Kafka等消息队列的数据源和数据目标。
- 腾讯云云服务器 CVM：腾讯云提供的弹性云服务器，可用于部署和运行Kafka集群。
- 腾讯云对象存储 COS：腾讯云提供的高可靠、低成本的对象存储服务，可用于存储Kafka的日志和数据备份。
以上是一些腾讯云的产品和服务，可根据具体需求选择适合的产品来支持和扩展Kafka的功能。
相关·内容
1回答
我与Avro一起使用合流模式注册表，我想在一个Kafka主题中使用多个模式。
默认主题命名策略TopicNameStrategy不允许这样做，因为它将模式主题名称耦合到主题名称。因此，您现在可以选择使用confluent.key.subject.name.strategy和confluent.value.subject.name.strategy将模式主题键和值配置为默认的命名策略而不是默认的命名<
浏览 11提问于2020-10-31得票数 2
回答已采纳
1回答
我正在使用confluent Kafka和模式注册表，但我想不出一种在python中使用自定义模式名称的方法。从这个blog中，我知道了如何在Java中做到这一点，但我不知道什么是等价物： properties.setProperty("value.subject.name.strategy", TopicRecordNameStrategy.class.getName在AvroProducer()中</e
浏览 18提问于2019-03-21得票数 1
回答已采纳
1回答
合流模式注册表超时错误
、、、
我使用Avro模式将数据写入Kafka主题。一开始一切都很好。在avro文件中再添加一个新字段(Scan_app_id)之后。我正面临着这个错误。Avro档案：{
“类型”：“记录”、“名称”："Initiate_Scan“、”命名空间“："avro”、"doc"：“Initiate_Scan的Avro模式注册表”、“字段”：{ "name"："”、“类型”：“字符串”、“文档”：“开发阶段”}、{“名称</e
浏览 1提问于2019-04-18得票数 2
1回答
在将清理策略设置为模式注册表后，我得到了一个模式未找到异常。错误是(stack_trace)：Caused by: io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException:Schema
浏览 4提问于2022-04-01得票数 0
我还依赖于io.confluent:kafka-schema-registry-client:6.2.0，，使用CachedSchemaRegistryClient在模式注册表中注册模式，如下所示：import io.confluent.kafka.schemaregistry.avro.AvroSchema
@transient lazy val现在，当我进行以下更改以指定正确的模
浏览 5提问于2022-03-03得票数 1
回答已采纳
我有一个主题，最终会有很多不同的模式。现在只剩下一个了。，我认为这个策略应该使用神奇的字节来获取模式，而不是主题名称，但是在主题上没有找到错误。我不确定它到底是在查找主题名称还是通过ID获取模式，无论是通过ssh-ing到connect实例，还是对http://schema-registry-service:8081/schemas/ids/7执行curl操作，我都会得到返回的模式。这
浏览 4提问于2019-04-22得票数 4
在confluent-5.5.0中，我无法更改max.request.size，它在ProducerConfig中默认为max.request.size = 1048576。/consumer.properties max.partition.fetch.bytes=15728640 confluent-5.5.0/etc/kafka-rest/kafka-rest.propertiesmax.request.s
浏览 170提问于2020-07-26得票数 2
回答已采纳
1回答
卡夫卡连接不使用主题策略
、、、
我使用将它们部署到本地Kafka环境中。但是，我想更改。默认的一个生成两个主题：
卡夫卡连接应该支持不同的主题策略。我设法解决了这个问题，编写了我自己的版本，并对
浏览 0提问于2018-11-28得票数 1
回答已采纳
我使用的是带有查询模式的jdbc源连接器，似乎没有指定表名的情况下，在模式注册表中为记录键和记录值注册的模式具有空的模式名称，并被分配了默认名称"ConnectDefault“，如Confluent的AvroData: Could not find class io.confluent.connect.avro.ConnectDefault specified in writer's schema
浏览 4提问于2017-11-03得票数 2
1回答
我正在生成一个Kafka记录，使用在schema Registry中注册的Avro模式。{"name":"first_name","type":"string","doc":"The string is a unicode character sequence."}]}"我正在下载模式，然后使用GenericRecord生成具有该模式的主题。我已经将subject value策略<
浏览 1提问于2020-07-19得票数 0
我正在使用confluent和kafka-connect-oracle ()跟踪Oracle数据库11g XE中的更改，我可以通过使用模式注册表api (如"curl -X GET “)查看模式内容：、”默认“：空}，{“名称”：“前面”、“类型”：“空”、“值”、“默认”：空}、“connect.name”：“test.kafkauser.test.row”}、“删除”：false}
但是，confluent的模式注册表
浏览 2提问于2021-06-01得票数 0
1回答
我有一个关于使用Kafka以及主题(Kafka broker)和主题(Schema Registry)的不同名称设置流处理器的问题。代理和模式注册表似乎一切正常，但是如果处理器接收到事件，模式注册表魔术就开始了。将发送abc.bla，而不是将abc作为主题发送到模式注册表。模式注册表的回答是not found。我想知道出了什么问题，因为单个生产者或消费者客户端似乎能够在没有显式配置的情况下从主题中识别出正确的主题名称。或io.
浏览 44提问于2021-11-15得票数 0
1回答
我正在尝试读取存储在S3中的avro记录，以便使用confluent提供的S3源代码将它们放回卡夫卡主题中。我已经有了具有正确模式的主题和注册表设置，但是当连接S3源代码试图将我的记录序列化到主题时，我会得到以下错误
org.apache.kafka.common.errors.SerializationException:错误注册Avro模式引起的：.在io.confluent.kafka.serializers.AbstractK
浏览 7提问于2022-07-07得票数 0
回答已采纳
我试图理解Kafka Streams API是如何与Schema Registry一起工作的。我知道在设置应用程序时必须指定Schema Registry URL，但我无法理解如果不指定主题名称或ID，应用程序如何从注册表检索正确的模式。
它使用主题名称检索模式？
浏览 2提问于2019-11-25得票数 2
1回答
我在经营合流码头。我试图添加更多的经纪人使用码头-撰写。这是我的docker-compose.yml。://localhost:9092 KAFKA_METRIC_REPORTER
浏览 2提问于2019-09-23得票数 0
回答已采纳
1回答
我试图在Kubernetes中部署Schema。: Error initializing kafka store while initializing schema registryd
浏览 37提问于2022-06-30得票数 0
我对kafka是个新手，我对Confluent平台很好奇。在Confluent平台上似乎没有太多的用户故事。Confluent平台和Apache Kafka有什么不同？
浏览 2提问于2016-09-26得票数 49
回答已采纳
我们正在使用kafka，并将avro模式和模式注册表设置为FULL兼容性。"logicalType": "timestamp-millis" ], }}
对于我们正在使用的非常旧的confluent-kafka但是，最近的confluent-kafka依赖于avro-python3 1.10，而消息序列化在</
浏览 9提问于2021-12-10得票数 5
在主题创建部分之前，一切都很好：docker exec -i schema-registry /usr/bin/kafka-avro-console-producer -检查名称的拼写，或者如果包含路径，请验证路径是否正确，然后再试一次。
所有融合的卡夫卡服务器运行良好。此时模式注册表为空：
PS C:\Users\J
浏览 5提问于2022-04-05得票数 0
回答已采纳
我尝试在分布式模式下运行kafka-连接-复制器，其中我更改了以下配置：
> advertised.listeners=PLAINTEXT://source.ip:9092> advertised.listeners=PLAINTEXT://
浏览 0提问于2019-07-22得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
