我使用以下代码运行模式注册服务器:
version: "2.2"
services:
schema-registry:
container_name: schema-registry
image: confluentinc/cp-schema-registry:5.5.0
restart: always
volumes:
- ./config:/tmp/conf
ports:
- "8081:8081"
environment:
- SCHEMA_REGISTRY_KAFKASTORE_BOOTSTRAP_SERVERS=localhost:9092
- SCHEMA_REGISTRY_KAFKASTORE_TOPIC=_schemas
- SCHEMA_REGISTRY_HOST_NAME=schema-registry
- SCHEMA_REGISTRY_LISTENERS=http://0.0.0.0:8081
- SCHEMA_REGISTRY_DEBUG=true
ulimits:
nproc: 65535
nofile:
soft: 65535
hard: 65535
logging:
driver: json-file
options:
max-size: "100m"
max-file: "3"
使用docker组件部署后,我得到以下错误:
[kafka-admin-client-thread | adminclient-1] WARN org.apache.kafka.clients.NetworkClient - [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
Kafka 在本地运行(它不在泊坞窗中运行),顺便说一句,kafka 服务器属性具有以下特性:
broker.id=0
侦听器=PLAINTEXT://localhost:9092
监听器.security.protocol.map=纯文本:纯文本,SSL:SSL,SASL_PLAINTEXT:SASL_PLAINTEXT,SASL_SSL:SASL_SSL
正如Chris所说,您需要将模式注册Docker容器连接到本地机器。或者,也可以在Docker中运行Kafka(或者也可以在本地运行Schema Registry,例如从作为汇合平台一部分的tarbar中运行)
分布式服务已成功启动:[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资源;服务器已启动并准备好处理请求(
我有一个docker容器运行AWS弹性容器服务(Fargate)中的confluentinc/cp模式注册表:5.5.0。只有一个容器正在运行。通过该模式注册表获取当前注册模式的API调用正在工作(例如,
我正在使用微软。蔚蓝色的数据计划主义。ApacheAvro 1.0.0-beta1和我正在尝试使用avro架构将事件发送到eventhub,但由于某种原因azure响应为BadRequest:Code“:400,“Detail:”架构验证失败:解析未定义的值路径“u0022typeu0022”时出错,第1行,位置17。我使用的是微软提供的例子,但我也没有运气。 记录={Schema:{“type”
下载confluent open source 3.3后在命令行做一个简单的实验: 合流启动-启动所有服务时不会出现任何可见错误:
我尝试使用批注将连接到 从数据库生成类。 例外情况是: null 有人有类似的问题吗?有什么解决办法吗?这可能是虫子吗?!
我已经在Ubuntu 16.04机器上安装了合流平台,并初步配置了zookeeper、Kafka和ksql,启动了合流平台。我可以看到下面的消息。 现在一切都启动了,当我检查融合平台的状态时,我观察到Schema注册表,连接 我已经检查了schema注册表的日志,找到了下面的日志。