参考以下舵图：https://github.com/confluentinc/cp-helm-charts 我正在尝试使模式注册表对k8s集群中的pods可用。为此，我向values.yaml和service.yaml添加了一个nodePort： values.yaml： ## External access.external: # type can be either NodePort or LoadBalancer
type: NodePort
浏览 22提问于2020-04-26得票数 0
回答已采纳
我在不同的k8s集群上设置了两个模式注册表，并使用nodeport服务在两个集群之间进行通信。我遵循了多数据中心模式注册表的以下步骤：https://docs.confluent.io/platform/6.0.0/schema-registry/multidc.html。主架构注册表配置： host.name=10.X.X.X (internal IP of schema registry pod)
kafkastore.gr
浏览 34提问于2021-09-21得票数 0
回答已采纳
我用舵机用部署卡夫卡cp-control-center: "confluent.schema.registry.url": http://data-cp-schema-registry:8081
浏览 11提问于2022-05-24得票数 0
回答已采纳
1回答
我是否需要一个模式注册表来实现我的目的？我相信Kafkacat不支持Avro，所以我想我必须坚持卡夫卡-生产者. so的卡夫卡安装(请纠正我，如果我错了)。
浏览 3提问于2021-03-31得票数 0
回答已采纳
1回答
已尝试使用SSL配置架构注册表。尝试将HTTPS架构注册表与AVRO Producer一起使用时，失败并显示错误我已配置为忽略主机名检查。但还是不起作用。ALso尝试从使用模式注册表的KSQL运行查询。失败，错误与找不到SAN名称的错误相同。下面是HTTPS架构注册表上的配置；ssl.keystore.location=/confl
浏览 5提问于2020-05-12得票数 0
1回答
我想通过卡夫卡Rest代理制作一个卡夫卡主题。我已经在模式注册中心中创建了一个JSON模式，我希望所有消息都根据注册的模式进行验证，如果它们与Schema不匹配，则被拒绝。{ "properties": { "type": "string", "bar": { }}
该模式
浏览 0提问于2020-06-25得票数 4
回答已采纳
{ "connection.urlvalue.converter.schemas.enable": "false", "key.ignore": "true"
} 我遵循了这里的示例：h
浏览 275提问于2020-04-14得票数 0
2回答
我在Kubernetes集群的容器中运行了confluent kafka、zookeeper、schema-registry和ksql。Kafka，zookeeper和模式注册表工作得很好，可以创建主题并以Avro格式写入数据，但当我尝试使用curl检查ksql并创建一些流时，例如：
curl -XPOST http://ksql-svc.someapp,"stackTrace":["io.confluent.ksql.ddl.commands.RegisterTopicCommand.ex
浏览 0提问于2018-03-18得票数 0
我知道在设置应用程序时必须指定Schema Registry URL，但我无法理解如果不指定主题名称或ID，应用程序如何从注册表检索正确的模式。
它使用主题名称检索模式？
浏览 2提问于2019-11-25得票数 2
2回答
我们在我们的堆栈中使用了Kafka、Kafka连接和Schema注册表。版本为2.8.1(合流6.2.1)。我们使用卡夫卡连接的信任(key.converter和value.converter)的价值: io.confluent.connect.avro.AvroConverter。它自动为主题注册一个新架构。如果我们指定请求参数defaultToGlobal，则返回全局兼容性。但是它不适用于我们，因为我们不能在请求中指定它。我们正在使用第三方UI: AKHQ。如何在通过AvroConverter注册新模
浏览 9提问于2021-10-21得票数 2
node 1 [/appl/node1/confluent-4.0.0] ./bin/confluent status elasticsearch-sink
io.confluent.kafka.schemaregistry.client.CachedSchem
浏览 2提问于2018-04-17得票数 0
3回答
模式注册表的集成
、、、
我正在开发一个应用程序(B)，它使用模式注册表并允许客户端(A)向任何其他平台(C)发送数据。总体设计:客户端A ->平台B ->目的地C
所以我不一定要向卡夫卡发布信息。是否有关于如何将模式注册表与未发布到kafka的自定义应用程序集成和使用的文档？我所能找到的所有文档都是与kafka一起使用注册表的。
浏览 4提问于2022-08-07得票数 1
对于流的输出，我使用Avro，并使用Confluent提供的Serde (io.confluent.kafka.streams.serdes.avro.SpecificAvroSerde)。我配置了一个独立的Schema Registry服务器，并在我的项目中将模式注册表设置为它(将 schemaRegistryClient.endpoint和schema.registry.url属性)。它将资源文件夹中可用的架构注册为.avsc文件。但是，当我发送一条消息时，Confluent序列化程序似乎继续将其作为
浏览 107提问于2020-09-24得票数 0
回答已采纳
我碰巧在5.0.1的窗口中看到了一个如何使用" schema -registry-start.bat“运行模式注册表的示例。
我在5.5.0中没有看到这个文件。现在windows中不支持架构注册表吗？这似乎只是通过dockers在windows中运行模式注册表的方法。请有人确认
浏览 5提问于2020-07-22得票数 1
回答已采纳
作业被配置为使用Table & SQL连接器和Confluent格式。但是，作业无法连接到架构注册表并引发401错误。(ConfluentSchemaRegistryCoder.java:74)我通过以下方法成功地测试了到Schema注册表的连接：
curl -u <SR_API_KEY我在这里查看了文档，其中只有3种格式选项描述了：" Format“、”Avro-confluent.schema-Regiy.url“、”Avro-conf
浏览 3提问于2021-02-08得票数 3
我正在使用confluent kafka-avro-console-consumer like like /kafka-avro-console-consumer --bootstrap-serverschema.registry.url=https://schemaregistry:443/ --consumer.config client-sasl-ssl.properties --from-beginning 它无法连接到架构注册表Handshaker.java:316)
at su
浏览 31提问于2019-08-24得票数 1
回答已采纳
目前，我们使用Avro作为消息格式，但是我们的基础设施中没有模式注册表。将来，我们计划用Confluent替换当前堆栈，并使用，但在一段时间内，我们只需要为此部署Connect。
浏览 0提问于2018-09-14得票数 7
回答已采纳
由于看起来是身份验证问题，我无法在Schema注册表中注册Avro Schema。我查看了SchemaRegistryClient的源代码，但似乎没有指定身份验证参数的选项。备注：我已经指定了以下属性，因为这些属性是在Confluent页面中建议的。sun.net.www.protocol.ht
浏览 1提问于2019-07-31得票数 1
回答已采纳
3回答
我一直在想，在使用静态类型化语言(如Java )使用Kafka主题的消息时，是否需要使用Avro模式注册表。KafkaConsumer<byte[], FooClass> kafkaConsumer = new KafkaConsumer<>(props);;
在我的项目中，我有.avsc文件来定义FooClass类的架构为什么我仍然需要指定架构注册表URL？我的使用者难道不能用我的项目中的.avsc文件反序列化我的Kafka消息的值吗？
浏览 5提问于2020-04-20得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
