当前位置: 首页 > 知识库问答 >
问题:

Confluent 3.3无法使用kafka-avro-console-producer在本地连接到架构注册表

宋宏毅
2023-03-14

下载confluent open source 3.3后在命令行做一个简单的实验:

合流启动-启动所有服务时不会出现任何可见错误:

confluent-3.3.0%   confluent start
Starting zookeeper
zookeeper is [UP]
Starting kafka
kafka is [UP]
Starting schema-registry
schema-registry is [UP]
Starting kafka-rest
kafka-rest is [UP]
Starting connect
connect is [UP]
confluent-3.3.0%   bin/kafka-avro-console-producer --broker-list localhost:9092 --topic test --property value.schema='{"type":"record","name":"myrecord","fields":[{"name":"f1","type":"string"}]}'
{"f1": "value1"}
[2018-06-28 12:22:47,827] ERROR Failed to send HTTP request to endpoint: http://localhost:8081/subjects/test-value/versions (io.confluent.kafka.schemaregistry.client.rest.RestService:156)
java.net.ConnectException: Connection refused

共有1个答案

曹成双
2023-03-14

贴出对我有用的东西,就像我看到许多其他类似问题的未回答的问题一样--可悲的是,重启我的笔记本电脑是起作用的。

在mac上,您可以使用Network Utility-->端口扫描来验证默认schema-registry端口8081上是否正在运行任何东西。

它显示为sunproxyadmin

在重新启动之前,该端口没有显示任何信息,尽管confluent status有时会将schema-registry报告为“up”。

 类似资料:
  • 我试图使用kafka-avro-console-producer 5.4.0-ccs不自动注册模式。我试着用: 但它仍然在注册模式。属性似乎正确:https://github.com/confluentinc/schema-registry/blob/a0a04628687a72ac6d01869d881a60fbde4177e7/avro-serializer/src/main/java/io/

  • 我正在尝试使用kafka-avro-convore-生产者发布一条具有键(带有模式)和值(带有模式)的消息。kafka环境(kafka的conFluent 6.2.0版本、连接、zoomaster、模式注册表)都正确启动,我可以确认我的连接器已安装。问题是当我发送消息时,我的Sink连接器失败并出现我无法诊断的错误。 感谢您的帮助: 我生成一条AVRO消息,如下所示: 并在连接日志中接收以下错误:

  • 分布式服务已成功启动:[2021 10月17日18:04:29693]信息已启动o.e.j.s.ServletContextHandler@1422ac7f{/,null,AVAILABLE}(org.eclipse.jetty.server.handler.ContextHandler:916)[2021 10月17日18:04:29693]初始化信息REST资源;服务器已启动并准备好处理请求(

  • 下午好,我最近才开始与Kafka合作,我有一个关于制作人与模式的问题。 最初,我尝试在C#中构建一个没有模式的简单生产者。到目前为止,这是可行的,代码也在一个简短的版本中给出。 无模式生产者代码: 但是模式会给我带来问题(请参阅下一节)。 假设我给了一个消费者,比如说Python中的消费者,他使用以下方案来接收整数: 我现在想创建一个使用此方案并向Python消费者发送消息的C#生产者。根据该方案

  • 嘿,我想将ConFluent模式注册表与Avro Serializers一起使用:留档现在基本上是说:不要为多个不同的主题使用相同的模式 谁能解释一下原因吗?我重新搜索了源代码,它基本上将模式存储在Kafka主题中,如下所示(topicname,magicbytes,version- 因此,除了冗余之外,我看不到多次使用模式的问题?

  • 我使用以下代码运行模式注册服务器: 使用docker组件部署后,我得到以下错误: Kafka 在本地运行(它不在泊坞窗中运行),顺便说一句,kafka 服务器属性具有以下特性: broker.id=0 侦听器=PLAINTEXT://localhost:9092 监听器.security.protocol.map=纯文本:纯文本,SSL:SSL,SASL_PLAINTEXT:SASL_PLAINT