REST WSO2 Kafka
REST（Representational State Transfer）是一种软件架构风格，用于构建分布式系统和网络应用程序。它基于HTTP协议，通过使用统一的接口和无状态的通信方式，实现了系统组件之间的松耦合和可伸缩性。
WSO2是一家提供开源中间件和云解决方案的公司。WSO2 API Manager是他们的一款产品，用于管理和监控API的生命周期。它提供了API的创建、发布、订阅、安全性管理和分析等功能。
Kafka是由Apache软件基金会开发的一种分布式流处理平台。它是一种高吞吐量、低延迟的消息队列系统，用于处理实时数据流。Kafka的核心概念包括生产者（Producer）、消费者（Consumer）和主题（Topic）。生产者将消息发布到主题，消费者订阅主题并处理消息。
REST和Kafka可以结合使用，以构建可扩展的分布式系统。通过使用REST接口，可以将消息发送到Kafka主题，并由消费者进行处理。这种架构可以实现高吞吐量和实时数据处理的需求。
在腾讯云中，可以使用API网关产品来实现REST接口的管理和安全性控制。API网关提供了API的发布、订阅、访问控制、流量控制和监控等功能。同时，腾讯云也提供了消息队列CMQ（Cloud Message Queue）来实现类似Kafka的功能，用于处理实时数据流。
腾讯云API网关产品介绍：https://cloud.tencent.com/product/apigateway 腾讯云消息队列CMQ产品介绍：https://cloud.tencent.com/product/cmq
相关·内容
我创建了两个WSO2企业服务总线集成项目，一个用于Kafka消息生产者，另一个用于Kafka消息消费者。我成功地在调用REST API时创建了Kafka消息生成器，并将消息放在主题上。当我创建Kafka消息消费者时，没有像Kafka这样的传输供代理监听，并且根据文档，我们需要使用IP端点来实现同样的传输。我的要求是，当消息在主题上可用时，应该在使用者处自动从主题(类似于JMS使用者)接收Kafka消息。那么我如何使用带有Kafka细节的IP端点来实现这一点呢？ 有什么建议吗？
浏览 30提问于2021-11-18得票数 0
回答已采纳
我的配置： kafka-rest-1:
image: confluentinc/cp-kafka-rest:6.2.1
hostname: kafka-rest-1
container_name: kafka-rest-1
depends_on:
- zookeeper-1
- broker-1
ports:
- "8082:8082"
environment:
KAFKA_REST_HOST_NAME: kafka-rest-1
KAFKA_REST_LISTEN
浏览 61提问于2021-10-19得票数 0
2回答
我有一个卡夫卡集群在码头使用合流图像。我正在用码头-构筑物建造集装箱。
当我试图运行容器时，它会启动，但由于SSL握手失败，无法与任何代理通信。我不知道我是不是错过了一些配置
org.apache.kafka.clients.NetworkClient - AdminClient clientId=adminclient-1连接到节点-3 (/XXX:19092)的连接失败，原因是: SSL握手失败
我的Kafka经纪人配置如下：
kafka1：
image: confluentinc/cp-kafka:5.2.2
container_name: kafka1
ports:
浏览 2提问于2019-06-25得票数 1
回答已采纳
1回答
我正在使用apache代理，使用坞编写，它使重日志文件比我的按摩大小更重，我有什么要设置的参数，或者要做些什么来禁用它？
kafka-schema-registry:
image: confluentinc/cp-schema-registry:latest
hostname: kafka-schema-registry
ports:
- "8082:8082"
environment:
SCHEMA_REGISTRY_KAFKASTORE_BOOTSTRAP_SERVERS: PLAINTEXT://kafka:9092
SCHEMA_REGISTRY
浏览 15提问于2022-03-19得票数 0
回答已采纳
我正在尝试使用docker设置Kafka rest代理。但是我在配置中提供的主题不是创建。
我正在用curl "http://metrics-kafka-rest:38082/topics"接口检查Kafka主题，得到的回应是：["__confluent.support.metrics","_schemas"]
下面是我在docker-compose中使用的配置：
image: confluentinc/cp-zookeeper:5.3.0
container_name: 'metrics-zookeeper'
浏览 16提问于2019-08-13得票数 5
回答已采纳
2回答
zookeeper和Kafka都沟通得很好，并且都在运行。
不确定为什么模式注册表和Kafka rest不能启动。
下面是docker-compose文件。
这是schema和rest docker-compose文件。此docker上的错误
[main] ERROR io.confluent.admin.utils.cli.KafkaReadyCommand - Error while running kafka-ready.
java.lang.RuntimeException: No endpoints found for security protocol [PLAINTEXT]. E
浏览 24提问于2020-05-21得票数 0
回答已采纳
我一直在使用spotify提供的kafka图像在本地运行kafka。我目前正在尝试将其用于cp-kafka-rest和schema-registry图像。
我需要帮助解决这个问题：
kafka_rest_1_609fd108dcf4**)**错误(日志组：)
main-SendThread(动物园管理员:2181)警告org.apache.zookeeper.ClientCnxn -服务器动物园管理员的会话0x0 :2181，意外错误，关闭套接字连接并尝试重新连接
java.nio.channels.UnresolvedAddressException
at sun.nio.ch.Net
浏览 0提问于2018-12-28得票数 0
回答已采纳
在来自WSO2的Api的2.6.0版本中，我使用自定义序列记录每个流量，其中包含API名称、资源、应用程序、令牌类型等.在输入和输出
<log level="custom">
<property expression="fn:concat('[V2][API][',$ctx:api.ut.application.name,'][',$ctx:API_NAME,'][',$ctx:AM_KEY_TYPE,'][',$ctx:REST_SUB_REQUEST_PATH,'][&
浏览 1提问于2020-09-18得票数 0
回答已采纳
1回答
因此，我在k8s上有两个类似的部署，它们从GitLab中提取相同的映像。显然，这导致我的第二次部署出现了CrashLoopBackOff错误，并且我似乎无法连接到端口来检查我的pod的/healthz。记录pod会显示pod在描述pod时收到中断信号，并显示以下消息。
FirstSeen LastSeen Count From SubObjectPath Type Reason Message
--------- -------- ----- ---- -
浏览 3提问于2018-11-29得票数 17
回答已采纳
3回答
嗨，我现在正在用Docker设置Kafka。我已经成功地使用发布的融合图像设置了Zookeeper和Kafka，请参阅以下docker-compose文件：
version: '2'
services:
zookeeper:
image: confluentinc/cp-zookeeper:3.2.0
container_name: zookeeper
hostname: zookeeper
ports:
- "2181:2181"
environment:
ZOOKEEPER_CLIENT_
浏览 0提问于2017-03-27得票数 19
1回答
我正在尝试让模式注册表运行，并且我看到了下面的异常。
ERROR Server died unexpectedly:
(io.confluent.kafka.schemaregistry.rest.SchemaRegistryMain:51)
org.apache.kafka.common.config.ConfigException: Only plaintext and SSL Kafka endpoints are supported and none are configured.
at io.confluent.kafka.schemaregistry.st
浏览 0提问于2018-11-07得票数 1
我正在使用maven 3运行应用程序，但是我得到了以下错误：
[ERROR] [ERROR] Some problems were encountered while processing the POMs:
[FATAL] Non-resolvable parent POM for io.confluent:kafka-rest:[unknown-version]: Could not find artifact io.confluent:kafka-rest-parent:pom:5.4.0-SNAPSHOT and 'parent.relativePath' points
浏览 7提问于2019-05-31得票数 2
我正在尝试使用https://github.com/llofberg/kafka-connect-rest上的社区贡献连接器来轮询来自HTTPs REST端点的数据。我的连接器的配置是as。如下所示： curl -X POST http://localhost:8083/connectors -H "Content-Type: application/json" -d '{"name": "rest-source-connector", "config":{"key.converter":"org
浏览 33提问于2020-03-21得票数 0
我试图在同一个kafka和动物管理员集群上挂载两个kafka模式注册表实例。但酋长一家混在一起了。在运行这两个注册中心时，如果我使用api "kafka- schema -registry“注册一个模式，它似乎是在”schema-registry other“创建的，而不是像预期的那样显示在”kafka-schema-registry“中。我的配置是：
version: '2.1'
services:
zoo1:
image: zookeeper:3.4.9
restart: unless-stopped
hostname: zoo1
浏览 6提问于2019-10-25得票数 1
回答已采纳
2回答
我已经在我的WSO2工作站上安装了Kafka Integration Studio version6.5.0，并使用Kafka Consumer and Producer内置模板创建了一个项目。 api.xml： <?xml version="1.0" encoding="UTF-8"?>
<api context="/publishweatherdata" name="WeatherDataPublishAPI" xmlns="http://ws.apache.org/ns/synapse"&
浏览 5提问于2020-09-21得票数 2
回答已采纳
我已经在本地启动了Kafka (2.8.0版)，并且正在运行Connect
connect-distributed.sh ../config/connect-distributed.properties ../config/snowflake-connector.json
并得到这个输出。
如何启动Snowflake连接器？
Oct 13, 2021 7:21:01 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime
WARNING: A provider org.apache.kafka.connec
浏览 0提问于2021-10-13得票数 1
1回答
我正在尝试在Kafka rest代理上应用mTLS安全，但没有成功。我正在寻找的模型如下。 浏览器--https://host:443/--> Kafka Rest代理--> Kafka代理 Kafka代理的rest代理工作得很好，但是客户端到rest代理只能与http://host:port/一起工作 我的Kafka-rest.properties如下。 id=kafka-rest-test-server
ssl.keystore.location=/Users/xxxx/kafka/keystore.jks
ssl.keystore.password=dummy
ssl.ke
浏览 27提问于2021-08-16得票数 1
回答已采纳
1回答
我输入"confluent start schema- registry“，它启动zookeeper，kafka，并在模式注册表失败。一分钟后，我再次输入该命令，它发现zookeeper和kafka已经在运行，并正常启动模式注册表。
我不能确定根本原因。这显然是与时间相关的东西。一旦它可以启动所有服务，一旦它在kafka上出现故障，大部分时间都是这样的。
schema-registry.log中的错误消息
ERROR Server died unexpectedly (io.confluent.kafka.schemaregistry.rest.SchemaRegistryMain)
浏览 0提问于2018-06-13得票数 1
我需要为REST API创建kafka源连接器与头部身份验证，如curl -H "Authorization: Basic“-H "clientID：”"https:< url for source>“。我使用的是apache kafka，我使用的是连接器类com.github.castorm.kafka.connect.http.HttpSourceConnector这里是连接器的json文件 {
"name": "rest_data6",
"config": {
&#
浏览 14提问于2020-09-06得票数 0
回答已采纳
我试图在Windows 10 Pro和Docker桌面(不是工具箱)上本地运行Kafka。一切看起来都很完美，但我无法用我的应用程序访问Kafka，也不能使用kafka rest ( \ / -这最后一个是我主机上的停靠ip )
我的停靠-撰写文件是：
version: '2'
services:
# https://hub.docker.com/r/confluentinc/cp-zookeeper/tags
zookeeper:
image: confluentinc/cp-zookeeper:5.3.1
container_name: zo
浏览 9提问于2019-10-21得票数 2
回答已采纳
1回答
我已经创建了一个接收器连接器来开始使用死信队列。但是，它显示模式没有发现异常，如下所示：
Caused by: org.apache.kafka.common.errors.SerializationException: Error retrieving Avro key schema version for id 103925
Caused by: io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException: Schema not found; error code: 40403
at io
浏览 10提问于2022-10-25得票数 0
2回答
我已经在Ubuntu16.04机器上安装了汇合平台，最初我已经配置了动物园管理员、Kafka和ksql，并启动了合流平台。我能看到下面的信息。
root@DESKTOP-DIB3097:/opt/kafkafull/confluent-5.1.0/bin# ./confluent start
This CLI is intended for development only, not for production
https://docs.confluent.io/current/cli/index.html
Using CONFLUENT_CURRENT: /tmp/confluen
浏览 2提问于2019-01-30得票数 5
嗨，我正在学习一个教程(不确定我是否可以在这里发布链接)来学习kafka连接。
我下载了合流-6.2.0
我运行这个命令
bin/connect-standalone etc/kafka/connect-standalone.properties
并得到以下消息
could not find or load main class org.apache.kafka.connect.cli.ConnectStandalone
我打印出它的类路径
$DIR/share/java/confluent-security/connect/*:$DIR/share/java/kafka/*:$DIR/sha
浏览 8提问于2021-10-22得票数 1
我正在尝试使用SASL验证我的Kafka rest代理，但我在将本地docker compose中的配置传输到Kubernetes时遇到了问题。 我正在使用JAAS配置来实现这一点。我的JAAS文件如下所示。 KafkaClient {
org.apache.kafka.common.security.plain.PlainLoginModule required
username="rest"
password="rest-secret";
};
Client {
org.apache.zookeep
浏览 16提问于2019-04-23得票数 2
回答已采纳
我刚刚开始使用卡夫卡，并希望使用来查看我所拥有的各种主题。
下面所示的docker-compomse.yml用于快速设置zookeeper、kafka、kafka-topics-ui，包括schema-registry和rest-proxy。
问题：在localhost:8000上加载kafka-topics-ui网站，当我们单击其中一个主题时，加载进度栏就会不停地动画，并且主题的任何消息都不会出现！
在查看浏览器JS控制台时，我们发现执行POST请求时出现了HTTP 415不支持的Media Type错误：
来自JS控制台的错误
angular.js:12587 POST http://lo
浏览 0提问于2018-12-02得票数 0
1回答
我正试图以avro模式的格式为我的kafka主题生成一些数据，但却出现了以下错误
org.apache.kafka.common.errors.SerializationException: Error registering Avro schema{"type":"record","name":"SampleData","namespace":"com.sample.examples","fields":[{"name":"count","t
浏览 8提问于2022-05-30得票数 0
回答已采纳
我在我的笔记本电脑上旋转了一个Kafka in Docker (带有docker-compose)。
之后，创建了新的kafka主题：
kafka-topics --zookeeper localhost:2181 --create --topic simple --replication-factor 1 --partitions 1
(尚未在架构注册表中创建架构)。
现在尝试生成(基于此示例-步骤3- )：
kafka-avro-console-producer \
--broker-list localhost:9092 --topic simple \
浏览 0提问于2018-04-24得票数 2
1回答
我正在创建一个向kafka-rest-proxy发送大量数据的服务。我只是发送数据(生产)给卡夫卡。我发现kafka-rest-proxy很容易被淹没并耗尽java堆空间。我已经分配了额外的资源，甚至横向扩展了运行kafka-rest-proxy的主机数量，但我仍然遇到连接中断和内存问题。 我不熟悉kafka-rest-proxy的内部结构，但我的直觉是它会缓冲记录并将它们异步发送给Kafka。如果是这样，那么它有什么机制来控制背压呢？有没有办法对它进行配置，让它同步地将记录写入Kafka？
浏览 31提问于2021-01-13得票数 1
我在我的Windows10Home上使用Docker运行了一个Landoop (image)容器，使用的是WSL2。我可以运行一个包含多个服务的docker-compose.yaml文件： #
# This docker-compose file starts and runs:
# * A 3-node kafka cluster
# * A 1-zookeeper ensemble
# * Schema Registry
# * Kafka REST Proxy
# * Kafka Connect
#
version: '3.7'
services:
zookee
浏览 25提问于2020-04-28得票数 0
我运行这个命令来提取图像，启动服务。
docker-compose -f dc-all.yml up
但是，我注意到数据保存在图像中，例如，一旦我放下和向上停靠，数据库数据就消失了，我试着向下停靠的命令。
docker-compose -f dc-all.yml down
保存数据的最佳实践是什么？
或者如何在不重新启动的情况下保持码头运行？例如，windows重新启动不会
样本yml文件
networks:
test:
services:
db:
networks:
- pm
image: microsoft/mssql-server-linux:2
浏览 3提问于2019-10-21得票数 1
回答已采纳
我使用docker运行kafka，在卷上设置存储数据。我设置了一些源连接器，主题是用cleanup.policy delete自动创建的。通过使用kafka经理，我将策略更改为compact。
问题：
在停止/启动停靠-组合主题出现后，但是cleanup.policy被恢复回delete。
问题：
重启后如何持久化主题配置？
附加信息
我命令重新启动卡夫卡码头工人：
rm /kafka/data/1/meta.properties; docker-compose down && docker-compose up -d --no-recreate
Docker-compose.
浏览 0提问于2020-10-21得票数 1
回答已采纳
在使用来自Kafka主题的消息时，我反复得到下面的异常。谁能解释一下这个异常是什么意思，以及如何避免它？
异常堆栈跟踪-
org.apache.kafka.common.errors.SerializationException: Error deserializing key/value for partition TEST-TOPIC1.0-0 at offset 0. If needed, please seek past the record to continue consumption.
Caused by: org.apache.kafka.common.errors.Ser
浏览 12提问于2018-01-16得票数 0
回答已采纳
1回答
我正试图将kafka rest代理与融合云连接起来。
kafka-rest-start ccloud-kafka-rest.properties
这是我的文件，有属性ccloud-kafka-rest.properties
client.ssl.endpoint.identification.algorithm=https
client.sasl.mechanism=PLAIN
consumer.request.timeout.ms=20000
bootstrap.servers=***-****.us-east-1.aws.confluent.cloud:9092
consumer.retr
浏览 3提问于2019-11-04得票数 0
6回答
码头工创作卡夫卡主题
、、、、
Problem：无法从坞撰写创建主题。在运行测试系统之前，我需要创建kafka主题。计划使用它作为管道的一部分，因此使用UI不是一个选项。
注意:卡夫卡需要15秒才能准备好，所以我需要在添加主题之前先睡上15秒。
可能的解决方案
创建一个包含命令等待15秒的shell.sh文件，然后添加一系列主题
为它创建一个dockerfile
在启动所测试的系统之前，将该坞映像包括在docker-compose.yml中。
电流
创建动物园管理员-好的
创建kafka1 - OK
rest-代理-好的
创建主题<- PROBLEM
创建SUT - OK
浏览 3提问于2020-11-16得票数 21
我使用如下所示的curl命令将两个模式添加到Schema注册表中(以及它们的共同响应)
curl -X POST -H "Content-Type: application/vnd.schemaregistry.v1+json" \
--data '{"schema": "{\"namespace\":\"org.example\",\"type\":\"record\",\"name\":\"personKey\",\"version\
浏览 3提问于2021-03-19得票数 0
希望输入subham:9092而不是172.16.6.86:9092作为我的bootstrapURL和schemaRegistryurl。
我在我的主机文件中有这个条目来解决。
172.16.6.86 subham-virtualbox
试着这么做，结果出错了，
Exception in thread "main" org.apache.kafka.common.errors.SerializationException: Error serializing Avro message
Caused by: java.net.MalformedURLException: unkn
浏览 3提问于2019-12-31得票数 1
回答已采纳
我在我的Windows工作站上安装了WSO2 IntegrationStudio6.5.0版本，并使用卡夫卡消费者和生产者内置模板创建了一个项目。
然后，我用自己的Kafka服务器设置(主题名为"myTopic")配置了该项目。
然后右击复合应用程序，选择Export工件并运行。
控制台窗口在最上面显示以下消息：
[2019-06-25 09:23:45,499] [micro-integrator] INFO - LibraryArtifactDeployer Synapse Library named '{org.wso2.carbon.connector}kaf
浏览 1提问于2019-06-25得票数 0
回答已采纳
我会将kafka-rest-proxy融合解决方案与apache kafka 2.0.0集成在一起
有人能解释一下我的集群如何只安装kafka rest代理吗?有3个节点kafka和3个znode？
浏览 20提问于2019-03-29得票数 0
1回答
我已经永久删除了kafka主题的模式，现在我无法从主题中反序列化消息，该怎么办。
堆栈跟踪：
Internal Server Error
A 500 error has occurred: Request processing failed; nested exception is org.apache.kafka.common.errors.SerializationException: Error retrieving Avro schema for id 100869
Stack trace
org.apache.kafka.common.errors.SerializationExce
浏览 12提问于2022-09-05得票数 -1
1回答
我的数据库在另一个Linux节点上，假设我和xxx.xx.xxx.xxx:3306在我的Windows机器上运行独立的kafka connect命令。我的server.properties代码是
name=test-source-mysql-jdbc-autoincrement
connector.class=io.confluent.connect.jdbc.JdbcSourceConnector
tasks.max=1
connection.url=jdbc:mysql://xxx.xx.xxx.xxx:3306/databasename?user=username&useSSL=
浏览 12提问于2019-03-28得票数 3
我使用Kafka Rest代理来生成和使用Azure APIM从Kafka主题消费，因此使用Rest代理的原因。我可以使用auto.offset.reset =最早的线性方式使用消息，所以每次调用Kafka Rest都会给我最新的消息，这是很棒的，
在以下情况下：
A1 is data requestor
B2 is API that fulfills A1's request using REST proxy for Kafka
C3 is Kafka Rest proxy server
如果A1向B2请求数据，而B2使用卡夫卡主题C3提供的消息给A1，但由于某些互联网问题，该消息
浏览 2提问于2022-07-21得票数 0
我的目标是将kafka-connect中的日志格式设置为json，但以下日志消息始终不是json，不能禁用：
Feb 10, 2020 4:36:03 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime
WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.RootResource registered in SERVER runtime does not implement any provider interfaces
浏览 1提问于2020-02-10得票数 1
2回答
我正在尝试在WSO2流集成器和本地Postgres之间设置更改数据捕获(CDC)。
我将Postgres驱动程序(v42.2.5)添加到SI_HOME/lib中，并且能够从Siddhi应用程序中读取数据库中的数据。
我遵循的例子来实现CDC，我使用pgoutput作为逻辑解码插件。但是，当我运行应用程序时，我会得到以下日志。
[2020-04-23_19-02-37_460] INFO {org.apache.kafka.connect.json.JsonConverterConfig} - JsonConverterConfig values:
converter.type
浏览 13提问于2020-04-23得票数 1
我不能启动模式注册表和kafka rest。当我使用kafka-rest-start时，会发生异常：
Exception in thread "main" java.lang.NoSuchFieldError: PASSWORD
我在哪里都找不到那是什么意思。
编辑
例外情况是：
Exception in thread "main" java.lang.NoSuchFieldError: PASSWORD
at io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig.baseSchemaRe
浏览 0提问于2018-02-06得票数 3
1回答
我试图在Kubernetes中部署Schema。然而，当我尝试用部署文件创建一个pod时，它总是以以下错误重新启动：
io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryInitializationException: Error initializing kafka store while initializing schema registry
at io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry.init(KafkaSchemaRe
浏览 37提问于2022-06-30得票数 0
1回答
我正在尝试读取存储在S3中的avro记录，以便使用confluent提供的S3源代码将它们放回卡夫卡主题中。我已经有了具有正确模式的主题和注册表设置，但是当连接S3源代码试图将我的记录序列化到主题时，我会得到以下错误
org.apache.kafka.common.errors.SerializationException:错误注册Avro模式引起的：.在io.confluent.kafka.serializers.AbstractKafkaAvroSerializer.serializeImpl(AbstractKafkaAvroSerializer.java:121) at io.conf
浏览 7提问于2022-07-07得票数 0
回答已采纳
使用kafka rest代理时对性能有何影响。
它会以何种方式影响其他kafka生产者/客户的表现？
使用kafka rest代理的缺点/缺点是什么？
浏览 3提问于2021-06-02得票数 0
我在Windows 10 PC (Ubuntu 18.04)上安装了Windows Subsystem Linux。我在Windows上安装了Docker工具箱，并通过VM运行，通过以下设置可以正常运行docker命令： export DOCKER_HOST=tcp://192.168.99.101:2376 我可以很好地访问它，并正确安装/运行docker容器。其中一个服务是运行在localhost:8084上的Kafka Connect容器，如果是从我的Windows创建的话。如果我直接从Ubuntu子系统运行它，我可以从我的Windows浏览器正常访问它，但是如果我从Windows子系
浏览 58提问于2020-04-27得票数 3
我有一个模式注册表，kafka，一个本地生产者运行的动物园管理员。问题是，当我手动注册模式并关闭生产者的自动注册时，当我试图为主题生成记录时，我会得到以下异常。令人困惑的是，在使用POST手动注册之后，我已经验证了模式是可用的，所以not没有真正的意义。在这方面的任何帮助都是非常感谢的。顺便说一句，在生产者上启用自动注册可以完成所有这些工作，但我确实需要关闭它并手动注册我的模式。
Caused by: io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException: Schema not found; e
浏览 8提问于2022-02-02得票数 0
我正在使用docker-compose.yml文件作为我的Kafka设置，这是正常工作的。当我试图连接到oracle数据库时，我还需要安装ojdbc驱动程序。因此，我修改了我的撰写文件以直接下载ojdbc jar，但是在添加了这段代码之后，我无法启动Kafka-connect。
文件中添加的附加代码:
command:
- /bin/bash
- -c
- /
cd /usr/share/java/kafka-connect-jdbc/
curl https://maven.xwiki.org/exter
浏览 1提问于2020-06-06得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
