使用相同域上的服务器访问Rest API for kafka架构注册表

文章/答案/技术大牛

发布

1回答

javascript、cors、apache-kafka

我在我的机器上设置了kafka，并启用了模式注册表。localhost:8081/schemas/ids/1localhost:5000我使用的是最新版本的kafka和模式注册表。并尝试使用JavaScr

浏览 7提问于2017-06-26得票数 0

回答已采纳

1回答

架构注册表安全配置

apache-kafka、confluent-schema-registry、apache-kafka-security

已尝试使用SSL配置架构注册表。尝试将HTTPS架构注册表与AVRO Producer一起使用时，失败并显示错误我已配置为忽略主机名检查。但还是不起作用。类似的配置在KAFKA REST、CONNECT和KSQL上也有效。 ALso尝试从使用模式注册表的KSQL运行查询。失败，错误与找不到SAN名称的错误相同

浏览 5提问于2020-05-12得票数 0

1回答

如何覆盖访问主机名和端口的架构注册表主节点

kubernetes、confluent-schema-registry

我在不同的k8s集群上设置了两个模式注册表，并使用nodeport服务在两个集群之间进行通信。如何告诉我的辅助模式注册中心使用可访问的主机名和端口号来连接主模式注册中心？我使用的是image confluentinc/cp-schema-registry:6.0.0。主架构注册表配置： host.name=10.X.X.X (internal IP of schema

浏览 34提问于2021-09-21得票数 0

回答已采纳

1回答

Kafka架构注册表-阻止在kafka中的模式注册表中不接受的消息

apache-kafka、confluent-schema-registry、kafka-rest

我在kafka中有一个模式，每次我在这个主题中发布一篇文章时，我注册的模式都会检查它是否是被发送的相同模式的。我的模式是：卷发柱： curl -X POST -H "Content-Type: application/vnd.schemaregistry.v1+json" --data '{"schemaname\":\"tipo_operacao\",\"type\":\&quo

浏览 8提问于2022-06-22得票数 0

1回答

使用合流consumers注册表，它是否必须与生产者/消费者使用的同样的Kafka对话？

apache-kafka、confluent-schema-registry

不幸的是，这是一个旧版本，0.10.2。我想开始使用Confluent注册表，从社区版的汇合平台。这将意味着安装旧的3.2.2模式注册表映像，以便与我们的旧kafka兼容。根据我在文档中所读到的，合流模式注册表似乎使用Kafka作为存储它的状态的后端。但是，生产/阅读Kafka主题的客户端独立于<em

浏览 3提问于2019-10-31得票数 0

回答已采纳

1回答

使用confluent_kafka为python注册架构ID和主题

apache-kafka、kafka-rest

到目前为止，我所得到的唯一答案是，您必须给模式和主题以相同的名称，然后它应该将它们连接在一起。curl -X POST -H "Content-Type: application/vnd.kafka.json.v2+json" -H "Accept: application/vnd.kafka.v2+json" -H "Accept: application/vnd.kafka.v2+json" -

浏览 1提问于2020-01-05得票数 1

回答已采纳

1回答

未能将HTTP请求发送到架构-注册表

apache-kafka、docker-compose、confluent-platform、confluent-schema-registry

我正在尝试设置一个本地kafka -连接堆栈与坞-撰写，我有一个问题，我的scala生产者，应该发送avro消息到一个卡夫卡主题使用模式注册表。在我的生产者(scala)代码中，我执行以下操作： val schemaRegistryUrl = "http:/(io.confluent.kafka.schemaregistry.rest<

浏览 4提问于2021-01-15得票数 0

回答已采纳

1回答

融合模式注册表与Go应用程序

java、go、apache-kafka、confluent-schema-registry

我理解(CSR)使用kafka进行模式存储。我正在尝试将CSR与一个golang应用程序集成。我的设置如下:客户端C连接到服务器S1(go应用程序)，S1写到另一个服务器S2。C -> S1->S2 我希望将CSR与S1集成在一起，以便当C向S1提交任何写时，S1将使用CSR根据各自的模式验证提交的数据。如果它是有效的，S1将把数据转发给S2。客户C在这里对CSR一无所知。我能找到的所有文档都是关于如何<

浏览 4提问于2022-08-11得票数 0

2回答

Confluent 4.0.0 Kafka连接-未找到架构注册表主题: org.apache.kafka.connect.errors.DataException：

apache-kafka、apache-kafka-connect、confluent-platform、confluent-schema-registry、ksqldb

(RestService.java:191)\n\tatio.confluent.kafka.schemaregistry.client.rest.RestService.lookUpSubjectVersion(RestService.java:284)\n\tat io.confluent.kafka.sc

浏览 2提问于2018-04-17得票数 0

1回答

为什么我需要创建一个卡夫卡消费者连接到模式注册表？

java、apache-kafka、confluent-schema-registry

ConsumerConfig只是一个具有所有所需配置的类。包括架构注册表URL。String> listOfSubjects = client.getAllSubjects();没有消费者，我得到：对消费者来说，一切都很好。我希望有人能对为什么会出现这

浏览 1提问于2019-01-02得票数 0

2回答

无法将Avro消息发布到Kafka主题

apache-kafka、kafka-producer-api

我使用以下命令启动了Kafka现在，我编写了一个简单的程序，将一个字符串发送到一个kafkaString]("test", "key2", &

浏览 0提问于2016-05-16得票数 1

1回答

Kafka连接BigQuery接收器从架构注册表请求不正确的主题名称

apache-kafka、google-bigquery、avro、apache-kafka-connect、confluent-schema-registry

当尝试在我们的Kafka (Avro)事件上使用confluentinc/kafka-connect-bigquery时，我遇到了以下错误： org.apache.kafka.connect.errors.DataExceptionfor id 619 Caused by: io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException:是的，在模式<e

浏览 58提问于2021-05-03得票数 0

回答已采纳

1回答

合流的架构注册表如何分配模式id？

apache-kafka、confluent-platform、confluent-schema-registry

我使用的是CachedSchemaRegistryClient和register方法，它接受一个subject和Avro模式。我是针对5.2.1汇流坞映像运行这些文件的，当我注册这个模式时，我会得到一些奇怪的行为。我注册的第一个模式返回一个id of 81 (通过使用模式注册表REST来检查该模式是否绑定到该id来备份)，然后第二个模式返回id为121。由于这种行为是出乎意料的，而且我一直无法通过Google找到答案，我很好奇是否有散

浏览 0提问于2019-08-07得票数 1

回答已采纳

1回答

为什么卡夫卡连接轻量级？

apache-kafka、streaming、spark-streaming、apache-nifi、apache-kafka-connect

我一直与卡夫卡连接，星火流，Nifi与卡夫卡的流媒体数据。我知道，与其他技术不同，kafka连接不是一个单独的应用程序，它是kafka的一个工具。

浏览 0提问于2018-07-19得票数 0

回答已采纳

2回答

Kubernetes上的架构注册表，可公开访问

kubernetes、apache-kafka、confluent-schema-registry

我在Azure上有一个三节点kubernetes集群，有三个Kafka代理和一个zookeeper实例。Kafka代理和zookeeper可以通过部署它们的对应服务(负载均衡器)公开访问。现在，我正在部署一个模式注册表，并且我希望可以从kubernetes集群外部访问它。我遵循与前面相同的步骤，但不能从kubernetes集群外部访问模式注册表api。以下是我的模式注册中心yaml

浏览 2提问于2018-11-27得票数 1

1回答

未能连接到合流平台架构注册表- Apache Confluent格式

apache-kafka、apache-flink、confluent-platform、confluent-schema-registry、flink-sql

我正在使用集群、Schema服务，并试图在Flink作业中处理Debezium消息。作业被配置为使用Table & SQL连接器和Confluent格式。但是，作业无法连接到架构注册表并引发401错误。：它看起来像是未经授权的错误消息"io.confluent.kafka

浏览 3提问于2021-02-08得票数 3

2回答

使用合流云和Kafka阻止CORS策略阻止API请求

cors、fetch-api、aws-amplify、svelte、confluent-cloud

我试图在融合云上的Kafka集群上发布一条信息。它在邮递员上运行得很好，但是当我试用我的Svelte应用程序时，我得到了以下错误：在svelte

浏览 15提问于2022-08-09得票数 3

回答已采纳

1回答

创建访问同一数据源的多个前端。

web、shared-hosting

我想使用相同的数据库创建和托管4-5个网站。这些网站之间唯一的区别是：我的第一个想法是使用API / Rest模型，并在自己的子域中提供五个前端。但是，由于站点可以托管在同一台服务器</e

浏览 3提问于2020-01-02得票数 0

回答已采纳

4回答

安全访问Kafka Connect的REST API

rest、apache-kafka、apache-kafka-connect

Kafka Connect的REST API未经过安全和身份验证。由于它未经过身份验证，因此任何人都可以轻松访问连接器或任务的配置。由于这些配置可能包含在SourceConnector情况下如何访问源系统，在SinkConnector情况下如何访问目标系统，是否有标准方法来限制对这些API的访问？

浏览 0提问于2017-07-22得票数 10

5回答

Kubernetes集群中的Kafka* --如何从Kubernetes集群外部发布/使用消息*

docker、apache-kafka、kubernetes

我使用的图像来自码头枢纽- 我不使用任何外部负载均衡器，但我有一个DNS，可以解决我的外部机器和库贝节点。在这种情况下，使用NodePort或ExternalIP公开Kafka服务不起作用。在Kafka YML中设置KAFKA_ADVERTIS

浏览 5提问于2017-01-26得票数 13

点击加载更多