如何设置Debezium for Kafka在Docker for MSSQL Server中运行
Debezium是一个开源的分布式平台，用于将数据库更改捕获为事件流。它可以与Kafka集成，以实时捕获和传输数据库更改事件。在Docker for MSSQL Server中运行Debezium for Kafka，可以通过以下步骤进行设置：
- 安装Docker：确保已在系统上安装了Docker。可以从Docker官方网站下载并按照说明进行安装。
- 下载Debezium for Kafka镜像：使用以下命令从Docker Hub下载Debezium for Kafka镜像：
- 下载Debezium for Kafka镜像：使用以下命令从Docker Hub下载Debezium for Kafka镜像：
- 创建Docker网络：运行以下命令创建一个Docker网络，以便Debezium和MSSQL Server可以进行通信：
- 创建Docker网络：运行以下命令创建一个Docker网络，以便Debezium和MSSQL Server可以进行通信：
- 启动MSSQL Server容器：使用以下命令启动MSSQL Server容器，并将其连接到创建的Docker网络：
- 启动MSSQL Server容器：使用以下命令启动MSSQL Server容器，并将其连接到创建的Docker网络：
- 请将"YourPassword123"替换为您自己的密码。
- 创建Debezium连接器配置文件：创建一个名为
debezium-connector.json的文件，并将以下内容复制到文件中： - 创建Debezium连接器配置文件：创建一个名为
debezium-connector.json的文件，并将以下内容复制到文件中： - 请将"YourPassword123"替换为您在第4步中设置的密码。
- 启动Debezium连接器容器：使用以下命令启动Debezium连接器容器，并将其连接到创建的Docker网络：
- 启动Debezium连接器容器：使用以下命令启动Debezium连接器容器，并将其连接到创建的Docker网络：
- 请将
/path/to/debezium-connector.json替换为包含Debezium连接器配置文件的实际路径。 - 验证连接器是否正常运行：使用以下命令检查Debezium连接器是否已成功启动：
- 验证连接器是否正常运行：使用以下命令检查Debezium连接器是否已成功启动：
- 如果返回状态码200和连接器的详细信息，则表示连接器已成功运行。
设置Debezium for Kafka在Docker for MSSQL Server中运行的步骤如上所述。通过这个设置，您可以实时捕获和传输MSSQL Server数据库的更改事件，并将其发送到Kafka集群中进行进一步处理和分析。
腾讯云相关产品和产品介绍链接地址：
- 腾讯云容器服务（TKE）：https://cloud.tencent.com/product/tke
- 腾讯云消息队列 Kafka：https://cloud.tencent.com/product/ckafka
- 腾讯云数据库 SQL Server：https://cloud.tencent.com/product/cdb_sqlserver
相关·内容
我想使用Kafka发布MSSQL事件。
我正在使用码头集装箱：
debezium/动物园饲养员
debezium/kafka
debezium/连接
集装箱的启动方式如下：
docker run -it --name zookeeper -p 2181:2181 -p 2888:2888 -p 3888:3888 debezium/zookeeper
docker run -it --name kafka -p 9092:9092 --link zookeeper:zookeeper debezium/kafka
docker run -it --name con
浏览 2提问于2019-06-02得票数 2
回答已采纳
我是Debezium、Kafka和Docker的新手。我已经成功地安装了Docker，并且它正在我的locahost上运行。 我正在尝试浏览Debezium教程，网址是：https://github.com/debezium/debezium-examples/blob/master/tutorial/README.md#debezium-tutorial 我转到SQL Server部分:第一步是# Start the topology as defined in https://debezium.io/docs/tutorial/。我成功地浏览了该教程。但是，它是用于MySQL的，而不是M
浏览 15提问于2020-04-03得票数 0
回答已采纳
1回答
我使用了debezium.io 提供的教程，并将其调整为使用MySQL数据库而不是MySQL，但是当我在数据库中进行更改时，观察者不会显示任何事件或活动。以下是我所采取的步骤：
我运行了动物园管理员码头命令：
docker run -it --rm --name zookeeper -p 2181:2181 -p 2888:2888 -p 3888:3888 debezium/zookeeper:1.1
然后我运行了kafka停靠命令：
docker run -it --rm --name kafka -p 9092:9092 --link zookeeper:zookeeper de
浏览 4提问于2020-06-12得票数 2
回答已采纳
我对Docker，Debezium，Bash和Kafka都很陌生。我试图在Windows 10上运行MSSQL的Debezium教程/示例：
我能够开始拓扑，每一步。但是，当我进入第二步并执行以下命令时：
cat debezium-sqlserver-init/inventory.sql | docker exec -i tutorial_sqlserver_1 bash -c '/opt/mssql-tools/bin/sqlcmd -U sa -P $SA_PASSWORD'
我得到以下错误：
bash: C:/Program:没有这样的文件或目录
我不知道为什么它会
浏览 2提问于2020-04-03得票数 1
回答已采纳
2回答
问题：
如何使用Kafka正确注册SqlServer连接器以连接到独立SqlServer实例？注意:我没有在Docker中运行Server。
错误：
com.microsoft.sqlserver.jdbc.SQLServerException:错误:由：连接到主机的/IP连接127.0.0.1，端口1433失败。错误：“连接拒绝(连接拒绝)。请验证连接属性。确保Server实例在主机上运行，并在端口接受TCP/IP连接。确保到端口的TCP连接不会被防火墙阻塞”。
Troubleshooting:
在Server配置管理器的Server ConfigurationDisabled Firew
浏览 4提问于2020-04-07得票数 1
回答已采纳
我的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
回答已采纳
我正在构建Kafka CDC，但根据文档，它运行许多docker-run命令。
我想把它全部放到一个docker-compose.yml中，但是我在最后一个命令时失败了，我不能转换成
以下是命令
docker run -d --name postgres \
-p 5432:5432 \
-e POSTGRES_USER=start_data_engineer \
-e POSTGRES_PASSWORD=password debezium/postgres:12
docker run -d --name zookeeper
浏览 22提问于2021-12-03得票数 0
我想用两个卡夫卡实例来篡改卡夫卡集群。
运行动物园管理员
docker run -it --name zookeeper -p 2181:2181 -p 2888:2888 -p 3888:3888 debezium/zookeeper
卡夫卡
docker run -it --name kafka -p 9092:9092 -e ADVERTISED_HOST_NAME=$(hostname -f) --link zookeeper:zookeeper debezium/kafka
运行一个动物园管理员和一个kafka是成功的，但添加第二个kafka容器如下所示
docker run -it
浏览 4提问于2019-09-24得票数 0
回答已采纳
我使用Apache Kafka和Debezium的连接器服务来查看我的表中的数据更改。另外，我使用的是亚马逊网络服务EC2，其中我有一个包含联邦表的数据库。如果我创建了一个非联邦表，并使用Zookeeper、Kafka和Kafka连接来运行我的docker观察器，我可以从该表中读取数据，但是当我看到一个联邦表时，就不能读取数据。 我试图在连接器的配置中添加一个查询，但这不起作用。 我的命令是： 启动Zookeeper $ docker run -it --rm --name zookeeper -p 2181:2181 -p 2888:2888 -p 3888:3888 debezium/z
浏览 20提问于2019-07-02得票数 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
1回答
对接MySQL数据库
、、、、
我是新来的debezium，正在尝试将我的kafka连接器连接到我在本地WAMP服务器上已经存在的MySQL数据库。
根据教程文档，我开始了动物园管理员和kafka，然后我启动了kafka连接器。在我的邮递员中，我向我的kafka连接器发送了以下JSON，但是我一直收到一个糟糕的请求响应。
启动Zookepper
docker run -it --rm --name zookeeper -p 2181:2181 -p 2888:2888 -p 3888:3888 debezium/zookeeper:0.7
启动卡夫卡
docker run -it --rm --name kafka -p 9
浏览 0提问于2018-06-21得票数 0
1回答
我遵循了以下步骤：
# Run postgres instance
docker run --name postgres -p 5000:5432 debezium/postgres
# Run zookeeper instance
docker run -it --name zookeeper -p 2181:2181 -p 2888:2888 -p 3888:3888 debezium/zookeeper
# Run kafka instance
docker run -it --name kafka -p 9092:9092 --link zookeeper:zookeeper de
浏览 6提问于2019-08-02得票数 0
我使用此示例将elasticsearch与mssql 同步
我使用这个mssql连接设置运行debezium 1.5：
{
"name": "Test-connector",
"config": {
"connector.class": "io.debezium.connector.sqlserver.SqlServerConnector",
"database.hostname": "192.168.1.234",
浏览 3提问于2021-06-19得票数 0
回答已采纳
debezium kafka connect命令是：docker run -it --rm --name connect -p 8083:8083 -e GROUP_ID=1 -e CONFIG_STORAGE_TOPIC=my_connect_configs -e OFFSET_STORAGE_TOPIC=my_connect_offsets -e STATUS_STORAGE_TOPIC=my_connect_statuses --link zookeeper:zookeeper --link kafka:kafka --link mysql:mysql debezium/connect
浏览 21提问于2019-06-05得票数 1
回答已采纳
目前，我正在WSL2环境中使用WSL2 12，我希望用debezium和kafka来实现cdc。由于我是第一次这样做，我搜索了所有的教程显示这个过程与码头。
在我的例子中，如果不是关于postgres的话，跟码头没有问题。我不想使用postgres/码头。
我只是想把debezium和kafka连接到我现有的磁盘上的postgres。请建议我的教程或方式，我可以联系。这将是一个巨大的帮助。谢谢。
我做了这两个步骤：
步骤1
docker run -it --rm --name zookeeper_debezium -p 2181:2181 -p 2888:2888 -p 3888:3888
浏览 2提问于2020-07-02得票数 0
1回答
我一直试图将数据从SQL server (启用更改跟踪)加载到Kafka，以便一个或多个系统(报表、其他DB等)能够使用这些数据。
我已经成功地为sql server(confluentinc/kafka-connect-cdc-mssql:1.0.0-preview)配置了卡夫卡连接插件，我还成功地在卡夫卡机器上启动了它。
我一直在寻找帮助回答以下问题的文档(找不到)
我如何将卡夫卡的主题与这种联系联系起来？
根据我发现的信息(在debezium论坛上)，将为每个表创建一个主题-->它是否与kafka sql server连接器的工作方式相同？
我在分布式模式下配置了连接，
浏览 0提问于2018-11-08得票数 2
我在尝试使用Camel Debezium SQL服务器连接器时遇到了一个问题。我正在尝试使用camel Debezium SQL server连接器捕获SQL server db表中的数据更改，并将它们放入message。我知道JDBC服务器连接可以选择使加密为false，以防止出现此问题。但我在Camel Debezium SQL服务器连接器中找不到类似的方法。
为了使用Camel Debezium SQL服务器连接器，我遵循了以下文档：
当我运行该应用程序时，它会显示以下错误：
错误-当试图运行由：'io.debezium.connector.sqlserver.SqlServ
浏览 41提问于2022-08-12得票数 2
回答已采纳
1回答
我试着用Debezium和Kafka来控制疾病控制中心。我已经在table.whitelist属性中注册了一个带有3个表的连接器，它正在正常工作。下面是正在运行的连接器的配置。
{"name":"xoom-eds-extactor","config":{"connector.class":"io.debezium.connector.mysql.MySqlConnector","database.user":"debezium","database.server.id"
浏览 0提问于2019-05-29得票数 2
回答已采纳
我在为我的应用程序编写dockerfile时遇到了问题。我的代码如下： # define a imagem base
FROM ubuntu:latest
# define a owner image
LABEL maintainer="MyCompany"
# Update a image with packages
RUN apt-get update && apt-get upgrade -y
# Expose port 80
EXPOSE 8089
# Command to start my docker compose file
CMD [&
浏览 84提问于2021-07-15得票数 0
我有一个spring应用程序，它应该连接到kafka。这是我的Docker文件查找spring应用程序的内容：
FROM maven:3-jdk-11 as builder
# create app folder for sources
RUN mkdir -p /build
WORKDIR /build
COPY pom.xml /build
#Download all required dependencies into one layer
RUN mvn -B dependency:resolve dependency:resolve-plugins
#Copy source code
浏览 3提问于2020-06-01得票数 1
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
我不能使用以下命令添加MySQL连接器： curl -i -X POST -H "Accept:application/json" -H "Content-Type:application/json" localhost:8083/connectors/ -d '{ "name": "useraccount-connector", "config": { "connector.class": "io.debezium.connector.mysql.MySqlConnector
浏览 56提问于2020-10-15得票数 2
伙计们。
让我先介绍一下情况：
我正在使用MS SQL SERVER中的两个表使用Debezium CDC Source Connector获取数据。根据连接器的要求：
提供者表连接器：
CREATE SOURCE CONNECTOR SOURCE_MSSQL_01_PROVIDER WITH (
'connector.class'= 'io.debezium.connector.sqlserver.SqlServerConnector',
'database.hostname'= '<URL>',
浏览 1提问于2021-07-15得票数 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
在此之前，我已经在SQL Server中基于此设置了CDC，并基于此将Debezium SQL Server连接器注册到Kafka connect。我运行Kafka消费者脚本，在SQL Server中执行一些修改数据(插入、更新和删除)，但Kafka消费者没有显示任何关于修改数据的JSON日志。
这是我的配置文件sqlserver-debezium.json：
{
"name":"sqlserver-debezium",
"config":{
"connector.class":"io.debezi
浏览 58提问于2020-05-05得票数 0
我正在尝试为需要运行多个docker容器的CDC (变更数据捕获)解决方案创建一个docker-compose文件。我的DockerComposeLocal.yml包含以下内容： version: "3"
services:
postgres:
image: debezium/postgres:12
ports:
- "5432:5432"
environment:
- POSTGRES_USER=postgres
- POSTGRES_PASSWORD=123
zookeper:
浏览 16提问于2021-08-16得票数 0
我是第一次接触kafka，正在使用debezium kafka来跟踪我的postgrest表中的变化。下面是我的docker-complse.yml
version: '3.8'
volumes:
shared-workspace:
name: "hadoop-distributed-file-system"
driver: local
services:
postgres:
restart: always
image: debezium/postgres
container_name: postgr
浏览 10提问于2021-08-27得票数 0
当我用这个堆栈设置我的Swarm时:Kafka(多代理)，zookeeper，debezium。Kafka和zookeeper正在工作，可以创建topic、consumer和producer，但debezium显示错误: org.apache.kafka.connect.errors.ConnectException:无法连接和描述Kafka集群。检查worker的代理连接和安全属性。我没有修改任何东西，只是默认配置为docker-stack：
version: '3.6'
services:
zoo:
image: wurstmeister/zookeepe
浏览 23提问于2018-08-03得票数 0
我对Kafka非常陌生(从一个星期开始在我的Sandbox环境中阅读和设置)，并尝试设置Server连接器。我已经按照汇合指南安装了Confluent社区，并使用confluent集线器安装了io.debezium.connector.sqlserver.SqlServerConnector，我在Server数据库和required表上启用了CDC，而且它工作得很好。
我尝试过以下连接器(一次一次)：
io.debezium.connector.sqlserver.SqlServerConnectorio.confluent.connect.jdbc.JdbcSourceConnector
这
浏览 4提问于2020-06-05得票数 0
回答已采纳
我是卡夫卡的新手，我正在尝试使用debezium postgres连接器。但是，即使使用postgres 11和标准插件，我也得到了以下错误: org.apache.kafka.connect.errors.ConnectException: org.postgresql.util.PSQLException: error:未能访问文件"decoderbufs"：没有这样的文件或目录
要运行kafka / debezium，我使用的是快速数据开发对接器的图像，如下所示
# this is our kafka cluster.
kafka-cluster:
ima
浏览 5提问于2020-01-30得票数 17
回答已采纳
我有一个码头组成的群与动物园管理员服务启动良好，但卡夫卡服务不能启动。
它一直使用默认的KAFKA_ADVERTISED_LISTENERS属性：
debezium_kafka.1.5hhrqfp5kqts@stephane-pc | Using ZOOKEEPER_CONNECT=zookeeper:2181
debezium_kafka.1.5hhrqfp5kqts@stephane-pc | Using KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://10.0.83.239:9092
当然，它也找不到映射中指定的侦听器：
debezium_kaf
浏览 0提问于2020-10-20得票数 1
debezium kafka连接命令是：docker run -it --rm --name connect -p 8083:8083 -e GROUP_ID=1 -e CONFIG_STORAGE_TOPIC=my_connect_configs -e OFFSET_STORAGE_TOPIC=my_connect_offsets -e STATUS_STORAGE_TOPIC=my_connect_statuses --link zookeeper:zookeeper --link kafka:kafka --link mysql:mysql debezium/connect:0.9
Pl
浏览 3提问于2019-06-05得票数 0
我最近尝试通过安装confluent-hub v1.6.0。
当加载插件时，连接器无法加载，这是由loadProperties在IoUtil中引发的，每个错误如下：
[2021-07-13 00:45:06,715] INFO Loading plugin from: /usr/share/confluent-hub-components/debezium-debezium-connector-postgresql (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader)
[2021-07-13 00:45:07,37
浏览 7提问于2021-07-13得票数 4
我正在尝试为Kafka更改数据捕获设置一个Docker文件环境，我遇到了以下错误：
打开到服务器的套接字连接0.0.0.0/0.0.0.0:2181。不会尝试使用SASL (未知错误)进行身份验证。
发生套接字错误: 0.0.0.0/0.0.0.0:2181:连接被拒绝
我一直在学习本教程，但它直接使用链接选项运行对接器命令，而不是使用docker-compose.yml文件。
我试图将这些转换为：
docker run -it --name kafka -p 9092:9092 --link zookeeper:zookeeper debezium/kafka
到下面的docker-
浏览 4提问于2021-02-07得票数 4
回答已采纳
1回答
我试图使用Debezium MYSQL连接器运行一个汇合连接服务的对接映像，但在运行该连接器后未能获得加载的类。
码头命令
docker run -d \
--name=kafka-connect \
--net=host \
-e CONNECT_BOOTSTRAP_SERVERS="b-2.<bootstrap_server>.us-east-1.amazonaws.com:9092,b-3.<bootstrap_server>.us-east-1.amazonaws.com:9092,b-1.<bootstrap_server
浏览 4提问于2020-05-12得票数 1
我没有找到任何关于Debezium如何设置Kafka消息时间戳的文档-以及是否设置了它。 从值的比较来看，Kafka消息时间戳始终落后于数据库表(source.ts_ms)更改的时间戳，也落后于Debezium (ts_ms)处理更改的时间。这表明Kafka消息时间戳只是由Kafka代理设置为摄取时间的时间戳。 有谁知道Debezium是否以及如何在它填充的接收器主题中设置Kafka消息时间戳的一些细节？ 我为SQL server使用了Debezium连接器，因为这会带来不同的结果。
浏览 42提问于2021-04-20得票数 0
在启用CDC功能之后，当我试图将Debezium连接到我的SQL Server数据库时，我收到以下错误消息：
java.lang.RuntimeException: Couldn't obtain database name,
at io.debezium.connector.sqlserver.SqlServerConnection.retrieveRealDatabaseName(SqlServerConnection.java:364),
at io.debezium.connector.sqlserver.SqlServerConnection.<init
浏览 4提问于2019-03-04得票数 2
回答已采纳
2回答
我试着用Debezium和卡夫卡连接，我跟踪，所有连接都很好。然而，问题是，我不能再从码头集装箱以外的卡夫卡。
我使用以下命令启动容器：
docker run -it --rm --name zookeeper -p 2181:2181 -p 2888:2888 -p 3888:3888 debezium/zookeeper:2.0.0.Beta1
docker run -it --rm --name kafka -p 9092:9092 --link zookeeper:zookeeper debezium/kafka:2.0.0.Beta1
docker run -it --rm --
浏览 3提问于2022-08-14得票数 0
回答已采纳
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
2回答
我是kubernetes的新手，我正在尝试将kafka与debezium和mysql集成。我成功地在minikube上部署了kafka和mysql，一旦我在minikube上部署了debezium yml，它就被挂起了，完全没有响应，然后我重新启动minikube，在运行完所有的pod minikube之后再次被挂起。下面是我的代码：
zookeeper服务
apiVersion: v1
kind: Service
metadata:
name: zoo1
labels:
app: zookeeper-1
spec:
ports:
- name: client
浏览 2提问于2018-12-08得票数 0
我使用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
回答已采纳
我正在尝试运行Debezium Server，这样我就可以使用GCP (谷歌) PubSub，而不必使用Kafka和Kafka连接器。我大部分时间都在运行它，但是，我在使用tranforms部分中的变量来定义主题名称时遇到了问题。 根据documentation，当使用发件箱转换时，我可以通过使用设置route.topic.replacement的变量${routedByValue}来选择主题名称，这将使用由设置route.by.field确定的值。如果省略替换设置，它将使用默认主题名称outbox.event.<route.by.field value>。 当我试图在'
浏览 55提问于2021-08-27得票数 0
我有一个与卡夫卡，动物园管理员和春季引导应用程序的对接-撰写文件。当我运行整个文件时，一切正常。当我在没有spring引导应用程序的情况下运行它时，为了通过intellij调试它，它无法连接到Kafka，并且不能正常工作。
我的船坞-撰写文件：
version: "3.5" services: # Install Zookeeper. zookeeper:
container_name: zookeeper
image: debezium/zookeeper:1.2
networks:
- mynetwork
ports:
浏览 2提问于2021-11-26得票数 0
回答已采纳
在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
1回答
正在尝试通过Debezium docker镜像连接到云上配置的Kafka。Debezium是否兼容所有Kafka版本？
浏览 57提问于2020-12-12得票数 0
1回答
无法连接:通信链接失败
、、、、
我正在尝试遵循教程。根据本教程，我也使用迷你库，但与码头司机。基本上就是一步一步地走下去。
但是，对于步骤“创建连接器”，在创建连接器之后
cat <<EOF | kubectl -n kafka apply -f -
apiVersion: "kafka.strimzi.io/v1alpha1"
kind: "KafkaConnector"
metadata:
name: "inventory-connector"
labels:
strimzi.io/cluster: my-connect-cluster
spec
浏览 3提问于2021-09-29得票数 0
回答已采纳
我刚接触Kafka，但Debezium Connect/Mysql在Docker中运行得很好。突然之间，所有docker容器都消失了，在重新启动并尝试重新连接到MySQL时，JDBC连接失败，并对Connect rest API做出以下响应： Using ZOOKEEPER_CONNECT=0.0.0.0:2181
Using KAFKA_LISTENERS=PLAINTEXT://172.19.0.5:9092 and KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://172.19.0.5:9092
HTTP/1.1 400 Bad Request
Date:
浏览 274提问于2021-05-01得票数 1
我正在使用docker通过以下命令运行zookeeper和kafka实例 docker run -it --rm --name zookeeper -p 2181:2181 -p 2888:2888 -p 3888:3888 debezium/zookeeper
docker run -it --rm --name kafka -p 9092:9092 --link zookeeper:zookeeper -e ADVERTISED_HOST_NAME=localhost -e HOST_NAME=localhost debezium/kafka ADVERTISED_HOST_NAME
浏览 49提问于2020-07-26得票数 1
1回答
我是运行Apache上的库伯内特斯通过斯特里齐运算符。我正在尝试用mysql debezium连接器安装Kafka Connect。
这是Connector配置文件：
apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaConnect
metadata:
name: my-connect-cluster
annotations:
strimzi.io/use-connector-resources: "true"
spec:
version: 3.1.0
replicas: 1
bootstrapServe
浏览 4提问于2022-05-30得票数 1
回答已采纳
我试图获得一个简单的Debezium堆栈(与Docker一起运行)，但是到Kafka broker的连接失败了。
这是我的简化docker-compose.yml
version: "3"
services:
zookeeper:
image: debezium/zookeeper:1.6
ports:
- "2181:2181"
- "2888:2888"
- "3888:3888"
kafka:
image: debezium/kafka:1.6
li
浏览 30提问于2021-07-30得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
