无法加载kafka connect debezium mongodb连接器
Kafka Connect Debezium MongoDB连接器是一种用于将MongoDB数据库与Kafka消息队列集成的工具。它可以捕获MongoDB数据库中的数据变化，并将其转换为Kafka消息，以便其他系统可以实时消费和处理这些数据。
该连接器的主要功能包括：
- 数据捕获：Kafka Connect Debezium MongoDB连接器可以监视MongoDB数据库中的数据变化，包括插入、更新和删除操作。
- 数据转换：连接器将MongoDB中的数据变化转换为Kafka消息的格式，以便其他系统可以方便地消费和处理这些消息。
- 实时同步：连接器可以实时地将MongoDB中的数据变化同步到Kafka消息队列中，确保数据的实时性和一致性。
- 可靠性保证：连接器具有故障恢复和容错机制，可以确保数据的可靠传输和处理。
- 可扩展性：连接器可以与Kafka集群无缝集成，支持水平扩展和高吞吐量的数据处理。
应用场景： Kafka Connect Debezium MongoDB连接器适用于以下场景：
- 数据集成：将MongoDB中的数据变化实时同步到其他系统，如数据仓库、实时分析系统等。
- 数据流处理：将MongoDB中的数据变化转换为Kafka消息，供流处理框架如Apache Flink、Apache Spark等进行实时处理和分析。
- 数据备份和恢复：通过将MongoDB中的数据变化写入Kafka消息队列，可以实现数据的备份和恢复，确保数据的可靠性和持久性。
推荐的腾讯云相关产品： 腾讯云提供了一系列与Kafka Connect Debezium MongoDB连接器相关的产品和服务，包括：
- 云消息队列CMQ：腾讯云的消息队列服务，可以作为Kafka消息队列的替代方案，用于存储和传输Kafka消息。
- 云数据库MongoDB：腾讯云的托管MongoDB数据库服务，可以作为Kafka Connect Debezium MongoDB连接器的数据源。
- 云流计算Flink：腾讯云的流处理框架，可以与Kafka Connect Debezium MongoDB连接器结合使用，实现实时数据处理和分析。
- 云函数SCF：腾讯云的无服务器计算服务，可以用于处理Kafka消息的消费和处理逻辑。
- 云监控CM：腾讯云的监控和管理服务，可以监控和管理Kafka Connect Debezium MongoDB连接器的运行状态和性能指标。
更多关于腾讯云相关产品的介绍和详细信息，请访问腾讯云官方网站：腾讯云。
相关·内容
下面是我在/etc/kafka/ MongoDB -mongodb-connect.中的配置
name=mongodb-source-connector
connector.class=io.debezium.connector.mongodb.MongoDbConnector
mongodb.hosts=/remoteserveraddress:27017
mongodb.name=mongo_conn
initial.sync.max.threads=1
tasks.max=1
但是越来越少的错误
ERROR Plugin class loader for connector:
浏览 10提问于2020-01-10得票数 2
回答已采纳
我不使用confluent，只使用apache kafka，已经添加了mongo插件，得到... / MongoSinkConnector -plugins响应，列出连接器
[
{
"class": "com.mongodb.kafka.connect.MongoSinkConnector",
"type": "sink",
"version": "1.5.0"
},
{
"class": "com.mongodb.kafka.connect.
浏览 3提问于2021-04-23得票数 1
嗨，我正在使用debezium捕获Mongo中的更改并将它们推入mysql --我使用下面的链接将end替换为mysql数据库，但我无法这样做。
这是我修改过的jdbc-sink.json，在这里我使用mysql url进行连接。
{
"name" : "jdbc-sink",
"config" : {
"connector.class":"io.confluent.connect.jdbc.JdbcSinkConnector",
"tasks.max"
浏览 0提问于2019-11-06得票数 0
我们可以限制我们在debezium mongodb连接器中的连接器属性中检索的数据量吗? configurations.As debezium在数据库中查找cdc，据我的理解，它是针对整个数据库的，我无法找到一种方法来限制很少的特定集合。我正在使用mongodb地图集连接链接在我的debezium连接器。
下面是我的连接器吐露：
{
"name": "inventory-connector",
"config": {
"connector.class" : "io.debezium.conn
浏览 1提问于2019-12-11得票数 1
我们正在运行Kafka Connect (汇合平台5.4，即。卡夫卡2.4)在分布式模式下使用Debezium (MongoDB)和汇合S3连接器。通过REST添加新连接器时，连接器是在运行状态下创建的，但没有为连接器创建任务。
暂停并恢复连接器无助于此。当我们停止所有员工，然后重新启动他们时，任务就会被创建，所有的事情都会按它应该运行的方式运行。
这个问题不是由连接器插件引起的，因为我们看到Debezium和S3连接器都有相同的行为。在调试日志中，我还可以看到Debezium正确地从Connector.taskConfigs()方法返回任务配置。
有人能告诉我怎么做吗?我们可以在不重新启动工
浏览 0提问于2020-02-21得票数 8
我已经使用debezium-connector-postgres-1.8.0.Final-plugin connector.Below是我的Standalone.properties文件成功地将postgresql连接到kafka：
rest.port=8084
bootstrap.servers=localhost:9092
key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=org.apache.kafka.connect.json.JsonConverter
key.convert
浏览 3提问于2022-02-08得票数 0
回答已采纳
我正在尝试将mysql与kafka连接起来。我下载了debezium-debezium-connector-mysql
这是我的connect-standalone.properties：
# These are defaults. This file just demonstrates how to override some settings.
bootstrap.servers=localhost:9092
# The converters specify the format of data in Kafka and how to translate it into Con
浏览 10提问于2019-11-19得票数 0
回答已采纳
我正试着为卡夫卡和德贝兹姆做一个POC。
我启动了卡夫卡和动物园管理员他们在工作..。现在当我尝试加载kafka连接时(我对此有点陌生.)我犯了一个错误，我就是不明白我做错了什么。
注意:我已经用Debezium教程的对接器映像测试了所有这些，但是我想从远程服务器连接，并且我认为在没有的情况下安装所有的东西都会更容易。
使用以下命令启动连接
./connect-standalone.sh ~/kafka/config/connect-standalone.properties ~/kafka/config/connect-standalone-worker.properties ~/kafka
浏览 2提问于2018-12-27得票数 2
回答已采纳
1回答
连接器任务状态无法连接
、、、
连接器的任务状态因错误而失败：
org.apache.kafka.connect.errors.ConnectException: java.lang.NoClassDefFoundError
我在分布式模式下运行kafka连接集群，并使用kafka(0.10.0.2.5)连接的ambari部署。
我使用导出CLASSPATH=/path给出了debezium mysql连接器路径。
使用以下命令将连接器配置加载到Kafka Connect中：
curl -i -X POST -H "Accept:application/json" \
-H "Co
浏览 0提问于2018-08-27得票数 0
回答已采纳
我需要实现CDC模式，但无法使其工作:我的debezium工作人员已经启动并运行，但我的连接器仍然失败，尽管我的努力。
我在我的mongo集群上测试了一个简单的“手表”，它起作用了：
watchCursor = db.mydb.watch()
while (!watchCursor.isExhausted()){
if (watchCursor.hasNext()){
print(watchCursor.next());
}
}
因此，我可以看出我的用户在集群上有观看变更的权限。
在运行任务时，我仍然有一个错误：
"tasks": [
{
浏览 31提问于2022-03-15得票数 1
1回答
我使用此页面上的说明在CentOS 7.9上安装了confluent平台。sudo yum install confluent-platform-oss-2.11 我使用的是带有apache版本2.6.1的AWS MSK集群。 我开始使用/usr/bin/connect-distributed /etc/kafka/connect-distributed.properties连接。我已经在distributed.properties中提供了MSK客户端端点作为引导程序。Connect启动得很好。然而，当我尝试添加下面的连接器时，它抛出了下面的错误。 连接器配置- {
浏览 72提问于2021-09-16得票数 0
回答已采纳
我试图使用Kafka在MongoDB和Elasticsearch之间建立一条简单的管道。插入的数据被成功地存储在Elasticsearch中，但是当我编辑或删除文档时，我只会得到另一个存储在Elasticsearch中的文档。这是我的MongoDB源连接器
{ "name": "mongo-source", "config": { "connector.class": "io.debezium.connector.mongodb.MongoDbConnector",
"mongodb.hosts&
浏览 4提问于2020-04-28得票数 0
回答已采纳
1回答
我在一个本地kubernetes集群中托管了Strimzi的Kafka + KafkaConnect，并且我正在尝试附加一个Debezium连接器，该连接器将通过SSL连接到远程mongo服务器。
我尝试过几种不同的配置，它们似乎都不允许我指定我通常用于身份验证的pem文件的路径。
我的蒙哥-结缔组织。这两种尝试都是这样的：
apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaConnector
metadata:
name: debezium-mongo-connector
labels:
strimzi.io/cluster: m
浏览 13提问于2022-10-13得票数 0
我试图使用Debezium的MongoDB源代码连接器(版本1.5.0)和Confluent的JDBC连接器(版本10.1.1)，通过Kafka将MongoDB (4.2.0版)与PostgresDB (版本10)连接起来。
对于源连接器，我有以下配置：
name=mongodb-debezium-source-connector
connector.class=io.debezium.connector.mongodb.MongoDbConnector
tasks.max=1
mongodb.hosts=rs0/127.0.0.1:27019
mongodb.name=gtmhub
tomb
浏览 9提问于2021-04-22得票数 1
我正在尝试编写一个kafka连接器，将kafka主题中的数据移动到mongodb(接收器)中。因为我已经在连接-json-Standalone.properties文件中添加了所需的配置，而且还在kafka文件夹中的connec-mongo-sink.properties文件中添加了所需的配置。在此过程中，在启动连接器时，我将获得以下异常
[2019-07-23 18:07:17,274] INFO Started o.e.j.s.ServletContextHandler@76e3b45b{/,null,AVAILABLE} (org.eclipse.jetty.server.handler
浏览 1提问于2019-07-23得票数 0
回答已采纳
我正在尝试为mysql数据库连接多个Debezium连接器，我的配置如下。
sudo docker run -it --name zookeeper -p 2181:2181 -p 2888:2888 -p 3888:3888 debezium/zookeeper:1.5 &
sudo docker run -it --name kafka -p 9092:9092 --link zookeeper:zookeeper debezium/kafka:1.5 &
sudo docker run -it --name connect -p 8083:8083 -e GROUP
浏览 1提问于2021-06-07得票数 0
我有一个现有的2 kafka服务器加载mysql连接器。它起作用了。此外，我需要添加MongoDB连接器。我已经在我的Kafka服务器(Centos7)上安装了confluent-schema-registry，它可以工作，我停止/启动/重新启动，看起来没有任何问题。我已经在这里下载并解压了debezium Mongo插件；/usr/connector/plugins/debezium-connector-mongodb/ 我已经编辑了/etc/schema-registry/connect-avro-distributed.properties，并修改了以下代码行： plugin.path
浏览 34提问于2020-01-22得票数 1
当我创建kafka jdbc源连接器(用于oracle的debezium连接器，使用confluent-5.4.0)时，收到错误消息“没有找到适用于jdbc的驱动程序:oracle:oci...”。
[2020-03-23 11:49:44,521] ERROR WorkerSourceTask{id=debezium-souce-inventory-0} Task threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:179)
org.apache.kafka.co
浏览 3提问于2020-03-23得票数 1
1回答
第一次使用Debezium时，我在debezium中每分钟只收到大约1000条消息(与在线基准相比非常慢)。没有节流卡夫卡连接/ MySQL/ Kafka经纪人，不知道我在这里做什么。我将在这里张贴配置，以供参考。
Kafka的配置-连接工作人员：
-e CONNECT_GROUP_ID="quickstart" \
-e CONNECT_CONFIG_STORAGE_TOPIC="quickstart-config" \
-e CONNECT_OFFSET_STORAGE_TOPIC="quickstart-offsets" \
-e CONN
浏览 7提问于2021-06-14得票数 1
在Ksqldb服务器中嵌入Kafka连接器时，“卷”映射似乎不起作用
下面是我的码头文件
ksqldb-server:
image: confluentinc/ksqldb-server:0.18.0
hostname: ksqldb-server
container_name: ksqldb-server
depends_on:
- broker
- schema-registry
ports:
- "8088:8088"
浏览 13提问于2021-07-20得票数 2
我让我的debezium mysql源连接器在Kafka上工作。我使用相同的数据库添加了另一个debezium mysql源连接器，但具有不同的数据格式。结果，我的第一个连接器开始显示以下错误：
[2019-07-11 10:29:09,125] ERROR WorkerSourceTask{id=debezium-connector-0} Task threw an uncaught and unrecoverable exception
(org.apache.kafka.connect.runtime.WorkerTask:177)
org.apache.kafka.connect.e
浏览 274提问于2019-07-11得票数 0
1回答
我正在使用KafkaCluster在K8s上部署KafkaConnect。
Strimzi算子集群图像:quay.io/strimzi/运算符:0.26.1
卡夫卡图像: quay.io/strimzi/ Kafka :0.26.1-kafka-3.0.0。
我正在尝试设置连接到Postgres的KafkaConnector。
以下是我的步骤：
从这个图像‘quay.io/strimzi/kafka:0.26.1-Kafka3.0.0’构建一个新的KafkaConnect。这个新的图片有插件，我从这个链接'‘下载
我在K8s上运行这个新映像，然后执行到K
浏览 7提问于2021-12-22得票数 0
我正在尝试创建一个带有转换的Debezium MySQL连接器来提取密钥。
在关键转换之前：
create source connector mysql with(
"connector.class" = 'io.debezium.connector.mysql.MySqlConnector',
"database.hostname" = 'mysql',
"tasks.max" = '1',
"database.port" = '3306&#
浏览 2提问于2020-05-20得票数 5
1回答
我已经在docker上使用终端上的curl创建了一个debezium连接器，并且我一直在修改现有的连接器。 我的docker文件： ---
version: '3'
services:
kafka-connect-02:
image: confluentinc/cp-kafka-connect:latest
container_name: kafka-connect-02
ports:
- 8083:8083
environment:
CONNECT_LOG4J_APPENDER_STDOUT_LAYOUT_CON
浏览 26提问于2020-01-21得票数 0
回答已采纳
1回答
我试图将MongoDB作为源连接到Kafka服务器，但是当我运行Debezium Mongo源连接器时，我得到了错误。我不明白为什么会超时？
[2019-08-22 13:28:58,194] INFO Cluster description not yet available. Waiting for 30000 ms before timing out (org.mongodb.driver.cluster:71)
[2019-08-22 13:28:58,648] INFO Exception in monitor thread while connecting to server mo
浏览 0提问于2019-08-22得票数 1
在org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:178)的org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execute(RetryWithToleranceOperator.java:104) at org.apache.kafka.connect.runtime.TransformationChain.apply(Tr
浏览 3提问于2020-06-26得票数 0
回答已采纳
我有一个debezium实例，它跟踪postgres上的更改并将更改消息发送给kafka。在kafka的另一端，我使用了带有amazon redshift sink connector的kafka connect，连接器所期望的消息格式与debezium发送给kafka的消息格式不兼容。有没有办法强迫debezium发送amazon redshift sink connector可以接受的消息？
浏览 2提问于2021-12-03得票数 0
2回答
我试图在mysql和elasticsearch之间进行事件流，我所面临的问题之一是将mysql中的JSON对象转移到elasticsearch时使用的是JSON字符串格式，而不是对象。
我在寻找SMT的解决方案，我找到了这个，
我不知道如何在卡夫卡中安装、装载或连接容器
这是我的拼图文件，
---
version: '2'
services:
zookeeper:
image: confluentinc/cp-zookeeper:6.2.0
hostname: zookeeper
container_name: zookeeper
po
浏览 12提问于2021-06-26得票数 1
回答已采纳
2回答
我正在尝试使用docker实现到mongodb和mysql的kafka连接。
我想要的是以下数字：
卡夫卡连接MongoDB:
我看过的船坞组合。它有两个问题：
对我来说太复杂了。因为它运行了mongodb的多个容器，并且使用了许多占用大量资源的映像。
它有一些问题还没有解决，最终导致卡夫卡与mongodb连接出现故障。你可以看到我的问题。
我使用debezium连接在docker-compose.yml中实现了以下内容：
version: '3.2'
services:
kafka:
image: wurstmeister/kafka:l
浏览 0提问于2019-08-18得票数 2
我正在尝试使用debezium/connect:1.3 docker图像，并在尝试使用此tutorial创建弹性水槽时遇到以下错误。 正如this撰写文件所建议的那样，使用似乎不可用的debezium/connect-jdbc-es。 {
"error_code": 500,
"message": "Failed to find any class that implements Connector and which name matches io.confluent.connect.elasticsearch.Elasticsear
浏览 89提问于2020-12-29得票数 1
回答已采纳
Error: failed to create containerd task: failed to create shim task: OCI runtime create failed: runc create failed: unable to start container process: exec: "/opt/kafka/kafka_connect_run.sh": stat /opt/kafka/kafka_connect_run.sh: no such file or directory: unknown
这是在kubectl kafka连接器吊舱中得到的，它
浏览 31提问于2022-10-18得票数 0
我的Dockerfile，用于下载接收器连接器和mysql jdbc驱动程序 FROM debezium/connect
ENV KAFKA_CONNECT_JDBC_DIR=$KAFKA_CONNECT_PLUGINS_DIR/kafka-connect-jdbc
ENV MYSQL_DRIVER_VERSION 5.1.39
ARG KAFKA_JDBC_VERSION=5.5.0
RUN curl -k -SL "https://dev.mysql.com/get/Downloads/Connector-J/mysql-connector-java-${MYSQL_DRIVER
浏览 34提问于2020-07-07得票数 0
回答已采纳
我使用Debezium MySQL连接器从我的数据库中捕获更改数据。在此之前，它可以很好地发挥作用。但是，现在，在我停止并重新启动连接器之后，连接器就不能工作了。我今天遇到了这个问题，我相信昨天做得很好。有人能帮忙吗？非常感谢!这些是错误消息。
[2021-02-11 01:19:13,581] INFO Kafka version: 6.0.1-ccs (org.apache.kafka.common.utils.AppInfoParser:117)
[2021-02-11 01:19:13,581] INFO Kafka commitId: 9c1fbb3db1e0d69d (org.ap
浏览 6提问于2021-02-11得票数 1
回答已采纳
我经常遇到与连接器本身创建的db历史主题相关的问题。有一个临时解决方案(通过更改db历史主题的名称)，我尝试过了，但是，这不是处理的更好的方法。另外，保留字节被设置为-1。这是错误堆栈。
ERROR WorkerSourceTask{id=cdcit.ventures.sandbox.streamdomain.streamsubdomain.order-filter-0} Task threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask)
io.debezium.Deb
浏览 2提问于2020-09-04得票数 2
我对使用Debezium有问题。我在网上搜索，但我找不到解决办法。我正在使用Windows 11和Kafka 3.1
以下是我的配置值：
Zookeepers.properties:
dataDir=C:/debezium/kafka/data/zookeper
clientPort=2181
maxClientCnxns=0
admin.enableServer=false
server.properties
broker.id=0
侦听器=明文://localhost:9092
num.network.threads=3
num.io.threads=8
socket.send.bu
浏览 7提问于2022-03-18得票数 0
1回答
我正在尝试使用Debezium将托管在Amazon RDS中的Postgres SQL数据库与Kafka主题连接起来。
我将遵循以下教程：
我的kafka和kafka连接服务启动正常，并且kafka连接服务还在/usr/share/java dir中获取我的debezium postgres连接器jars。
但是，在尝试通过kafka connect API附加postgres config json时，请使用以下curl命令：
curl -i -X POST -H "Accept:application/json" -H "Content-Type:applicat
浏览 4提问于2018-06-14得票数 2
2回答
我正在尝试使用Debezium连接到我本地机器上的mysql数据库。
尝试使用以下命令调用kafka: sudo kafka/bin/connect-standalone.shsh kafka/config/connect-standalone.properties kafka/config/connector.properties
下面是connector.properties中的配置：
{
"name": "inventory-connector",
"config": {
"connector.class":
浏览 0提问于2018-12-07得票数 3
[用户在上发布的问题]
我试图从CDC (YugabyteDB 2.13)读取JSON格式的数据，为此我使用了以下配置：
connector.class=io.debezium.connector.yugabytedb.YugabyteDBConnector
database.streamid=88433e52543c4ecdb20934c6135beb3f
database.user=yugabyte
database.dbname=yugabyte
tasks.max=7
database.server.name=dbserver1
database.port=5433
database.
浏览 3提问于2022-05-20得票数 0
回答已采纳
我正在使用Debezium mongodb连接器来流式传输来自mongo中30 in集合的更改。 这是我的配置： "config": {
"connector.class" : "io.debezium.connector.mongodb.MongoDbConnector",
"tasks.max" : "1",
"mongodb.hosts" : "",
"mongodb.name" : "",
"m
浏览 29提问于2019-02-18得票数 1
回答已采纳
我试图使用MongoDB debezium连接器从Kafka捕获数据，但是当我尝试用KafkaJS读取数据时，会出错：
KafkaJSProtocolError: The group member's supported protocols are incompatible with those of existing members
我正在使用码头图像来捕获数据。
以下是我要做的步骤：
启动动物园管理员
码头运行-it -rm-名动物园管理员-p 2181:2181 -p 2888:2888 -p 3888:3888 debezium/动物园管理员:最新消息
启动卡夫卡
码头
浏览 0提问于2019-03-27得票数 0
回答已采纳
比方说，我将获得多个MySQL实例，并且必须流式传输实时数据。为此，我使用下面列出的命令在Docker Container上启动了一些服务，这些命令将我连接到示例库存数据库，并且当我在MySQL命令行客户端中执行任何DML命令时，都能够监控这些数据的变化。
但是，连接到实际的MySQL数据库并在观察器窗口中传输相同的内容所需的更改或等效命令是什么呢？
docker run -it --rm --name zookeeper -p 2181:2181 -p 2888:2888 -p 3888:3888 debezium/zookeeper:1.1
docker run -it --rm --n
浏览 2提问于2020-05-27得票数 1
我需要将MySQL数据库复制到PostgreSQL数据库。我选择了：
Debezium连接
Avro格式
合流模式注册表
卡夫卡
数据正在被复制，但是，我正在丢失一些模式信息。例如，在Postgres中将具有mysql格式的datetime格式的列复制为bigint，没有创建外键，也没有保留列的顺序(这很好)，等等。
PostgreSQL接收器连接器：
{
"name": "jdbc-sink-dbt",
"config": {
"connector.class": "
浏览 1提问于2022-01-14得票数 0
回答已采纳
2回答
使用debezium从Postgres中更改流
已完成的设置：
码头设置。
启动Postgres，动物园管理员，kafka，然后去贝兹姆连接器。
远程数据库设置与解码，wal2json(postgres)。
用卷曲连接到去贝兹姆。
创造了一个观察者。
问题:当我开始观察时，它正在读取前面发生的所有更改，但是当插入完成时，卡夫卡向debezium抛出一个异常，上面写着"An exception occurred in the change event producer. This connector will be stoppe
浏览 1提问于2019-05-02得票数 2
回答已采纳
1回答
复制槽已存在
、、
每当我重启debezium kafka-connect容器，或者部署另一个实例时，我都会得到以下错误：
io.debezium.jdbc.JdbcConnectionException: ERROR: replication slot "debezium" already exists
at io.debezium.connector.postgresql.connection.PostgresReplicationConnection.initReplicationSlot(PostgresReplicationConnection.java:136)
浏览 0提问于2018-06-08得票数 6
正如标题所述，我使用debezium Postgres源连接器，并且我希望MongoDB接收器连接器根据不同的集合和数据库(也不同的dbs来分离无关数据)中的名称对kafka主题进行分组。在询问时，我在上看到了连接器属性。不幸的是，这只为每个kafka主题创建了一个集合，该集合成功地与指定的regex匹配，我计划使用相同的mongodb服务器来存储从多个debezium源连接器中捕获的许多dbs。你能帮帮我吗?
注意:我读过这个Mongo接收器设置FieldPathNamespaceMapper，但我不确定它是否符合我的需要，也不确定如何正确配置它。
浏览 14提问于2022-09-24得票数 0
我正在使用Debezium修补从MongoDB到Kafka的流式更改，并且在Debezium尝试访问MongoDB副本集时遇到某种权限问题。 docker-compose.yml version: "3"
services:
mongodb:
image: mongo
container_name: mongodb
hostname: mongodb
restart: always
ports:
- 27017:27017
volumes:
浏览 83提问于2021-05-11得票数 0
4回答
我正在尝试将我的SQL Server数据库连接到windows上的kafka，我下载了Debezium jar文件，它们位于一个名为debezium-connector-sqlserver的文件夹中，如下所示：，
我还在connect-standalone.properties中添加了这一行plugin.path=C:\\current_kafka_2.12-2.0.0\\debezium-connector-sqlserver，这是我从Debezium下载的所有jar文件的位置。
我还创建了一个名为connect-mssql.properties的文件，并将其放入其中。
name=inven
浏览 1提问于2019-02-21得票数 2
2回答
我正在运行一个docker文件，作为切入点执行debezium服务。
当我在docker文件中使用精确的文件路径作为入口点命令的参数时，它可以很好地工作，并执行debezium服务。
命令在停靠文件中
入口点"kafka_2.12-2.6.2/bin/connect-standalone.sh"，"kafka_2.12-2.6.2/config/connect-standalone.properties"，"kafka_2.12-2.6.2/worker.properties“
，但是当我将文件名作为环境变量传递时，它失败了。
命令在停靠文件中
入口点$
浏览 6提问于2022-06-14得票数 0
我在卡夫卡connect.While启动连接器中使用debezium oracle连接器，
java.lang.RuntimeException: Failed to resolve Oracle database version
at io.debezium.connector.oracle.OracleConnection.resolveOracleDatabaseVersion(OracleConnection.java:159)
at io.debezium.connector.oracle.OracleConnection.<init>(O
浏览 5提问于2021-09-07得票数 3
回答已采纳
我使用debezium cdc连接pg，我构建了由码头使用的pg 11，pg运行良好。当我在kafka连接器中使用debezium时，它报告：
无法获得数据库测试的编码
卷曲是：
curl -H "Accept: application/json" -H "Content-type: application/json" -X POST http://localhost:8083/connectors/ -d '{
"name": "debezium",
"config": {
浏览 18提问于2020-07-08得票数 3
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
