PostgresConnector:在此连接器上未发现主题
PostgresConnector是一个用于连接PostgreSQL数据库的连接器。它允许应用程序通过网络与PostgreSQL数据库进行通信和交互。
PostgreSQL是一种开源的关系型数据库管理系统，具有可扩展性、稳定性和安全性等优势。它支持复杂的查询和高级数据类型，同时也提供了许多扩展功能和插件，使其适用于各种应用场景。
PostgresConnector的主要功能是建立应用程序与PostgreSQL数据库之间的连接，并提供数据传输和交互的能力。它可以通过使用PostgreSQL的客户端库来实现与数据库的通信，并支持各种编程语言和开发框架。
应用场景：
- Web应用程序：PostgresConnector可以用于开发Web应用程序，通过与PostgreSQL数据库进行连接，实现数据的存储和检索。
- 数据分析和报告：通过连接到PostgreSQL数据库，可以使用PostgresConnector将数据导出到数据分析工具中，进行数据分析和生成报告。
- 实时数据处理：PostgresConnector可以用于实时数据处理应用程序，通过与PostgreSQL数据库进行连接，实时地读取和写入数据。
- 日志和监控：通过连接到PostgreSQL数据库，可以使用PostgresConnector将日志和监控数据存储到数据库中，以便后续分析和查询。
腾讯云相关产品推荐： 腾讯云提供了一系列与数据库和云计算相关的产品和服务，以下是一些推荐的产品和产品介绍链接地址：
- 云数据库 PostgreSQL：腾讯云的托管式PostgreSQL数据库服务，提供高可用性、可扩展性和安全性。详情请参考：https://cloud.tencent.com/product/postgres
- 云数据库 PostgreSQL for Serverless：腾讯云的无服务器PostgreSQL数据库服务，根据实际使用情况自动扩展和收缩计算资源。详情请参考：https://cloud.tencent.com/product/serverless-postgresql
- 云数据库 PostgreSQL for Redis：腾讯云的PostgreSQL和Redis的混合型数据库服务，提供高性能的内存数据库和关系型数据库的结合。详情请参考：https://cloud.tencent.com/product/redis-postgres
- 云数据库 PostgreSQL for Time Series：腾讯云的面向时间序列数据的PostgreSQL数据库服务，适用于物联网、日志和监控等场景。详情请参考：https://cloud.tencent.com/product/tspg
请注意，以上推荐的产品和服务仅供参考，具体选择应根据实际需求和情况进行评估和决策。
相关·内容
我在Laravel5.2工作，我正努力让它和Vertica一起工作。几个月前，我和我的同事想出了一个解决方案，但我们现在正试图减少一些麻烦，并使用服务提供商来使事情正常进行，这样我们才能更容易地升级Laravel。到目前为止我们所做的是：
1)创建两个扩展对应类的新类：
新BaseConnector：
namespace App\Vertica;
include 'clsPDOVertica.php';
use Illuminate\Support\Arr;
use \Illuminate\Database\Connectors\Connector as BaseConnec
浏览 0提问于2017-03-03得票数 4
回答已采纳
当使用 Docker图像时，不会为我的表创建一个Kafka主题。下面是我如何启动容器的方法：
docker run -it --rm --name debezium -p 8083:8083 -e GROUP_ID=1 -e CONFIG_STORAGE_TOPIC=my-connect-configs \
-e OFFSET_STORAGE_TOPIC=my-connect-offsets -e BOOTSTRAP_SERVERS=192.168.56.1:9092 \
-e CONNECT_NAME=my-connector -e CONNECT_CONNECTOR_CLASS=io.d
浏览 14提问于2022-10-19得票数 0
我正在尝试使用debezium kafka连接以下设置的cdc：
ZookeeperKafka PostgreSQLKafka连接Debezium
我还按照这个顺序配置和启动它们。
启动Kafka Connect Debezium之后，我做了一个帖子来配置它：
{
"name": "postgres-boxes-connector",
"config": {
"connector.class": "io.debezium.connector.postgresql.PostgresConnector"
浏览 3提问于2019-11-27得票数 0
回答已采纳
我正在运行ladoop/fast-data-dev并使用Debezium的PostgresConnector。我已经配置了连接器，但是没有创建主题。 在此连接器上未发现主题是错误。 Docker-compose集群： kafka-cluster:
image: landoop/fast-data-dev:latest
environment:
ADV_HOST: 127.0.0.1 # Change to 192.168.99.100 if using Docker Toolbox
RUNTESTS: 0
浏览 20提问于2019-05-12得票数 2
我成功地在Postgres DB中生成了CDC。今天，当我使用相同的步骤尝试为另一个Postgres DB设置Kafka Debezium连接器时。
我先跑了
POST
身体：
{
"name": "postgres-kafkaconnector",
"config": {
"connector.class": "io.debezium.connector.postgresql.PostgresConnector",
"tasks.max":
浏览 20提问于2022-02-15得票数 0
回答已采纳
我有一个CDC设置的Postgres DB。
我为Postgres DB部署了Kafka Debezium连接器1.8.0。
POST
身体：
{
"name": "postgres-kafkaconnector",
"config": {
"connector.class": "io.debezium.connector.postgresql.PostgresConnector",
"tasks.max": "1",
浏览 4提问于2022-02-17得票数 0
回答已采纳
我正在使用debezium连接器实现一个发件箱模式，建立在官方文档的基础上。
一切都很好--除了属性"transforms.outbox.table.expand.json.payload: true“不起作用外。
使用以下数据库记录(SQL )：
INSERT INTO public.outbox_event_entity (id, event_id, "key", payload, topic, "type") VALUES(0, 'e09d6355-8e7c-4055-936c-4f997423925e', '1',
浏览 8提问于2021-12-12得票数 0
回答已采纳
7回答
当我们使用Debezium和Postgres时，我们看到的是心跳似乎不起作用的问题。我们已经在目标数据库中创建了一个虚拟表，用于执行心跳操作，但我们从未看到对该表中的数据进行任何更改。
我们启用了心跳，因为我们看到的是它设计的相同的行为，即。
我们正在使用Postgres 12，Debezium 1.3 (或1.5，已经对两者进行了实验)
配置是
{
"name": "my-service-outbox",
"config": {
"connector.class": "io.debezium.conn
浏览 10提问于2021-02-09得票数 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
使用JDBC同步连接器获取以下错误。
ERROR WorkerSinkTask{id=12sink-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted. Error: Cannot ALTER TABLE "new1501"."test"."patient3" to add missing field SinkRecordField{schema=Sche
浏览 7提问于2022-02-11得票数 0
1回答
我想使用汇流接收器连接器更新远程服务器上的Postgres数据库。平均每天我们可能有1000到2000条消息(更新)。创建数百个接收器连接器以将这些消息复制到所有远程服务器是否“合法”？有这么多接收器连接器是正常的吗？
是否有可能告诉接收器连接器“传播”他们的工作，这样不是所有的100个连接器都会同时将更改推送到远程服务器上吗？应该使用"timestamp.delay.interval.ms“吗？
谢谢
浏览 1提问于2021-01-18得票数 0
回答已采纳
我浏览了，但不知道如何指定分区和集群键。
医生说：
可以将此连接器配置为管理Cassandra集群上的架构。更改现有表时，该键将被忽略。这是为了避免在更改现有表上的主键时可能出现的问题。键架构用于创建表时为其生成主键。
如果它是一个新表，连接器将使用键模式(我想是来自KStream )来创建主键。对于分区键来说，这可能是可以的，但是对于集群键，这可能是可以的。
那么，在运行这个流应用程序之前，我们是否必须创建所有具有正确键的表，还是有一种调整方法？
浏览 1提问于2020-04-04得票数 2
回答已采纳
我有一个相对简单的postgres源代码my-connector，作为一个debezium/connect:latest停靠容器运行。
{"name":"my-connector","config":
{"connector.class":"io.debezium.connector.postgresql.PostgresConnector",
"database.user":"postgres",
"database.dbname":"postgres
浏览 2提问于2021-03-22得票数 0
回答已采纳
我让Kafka运行在合流云上，在那里我可以使用Node.js客户机生成数据，数据以字符串的形式发送，我可以在合流云中得到以下字段。
然后，我创建了一个ElasticsearchSink Connector，并将它连接到弹性搜索云。如果我没有在弹性搜索中创建任何映射，数据传输是成功的例外，格式是这样的。
"_source" : {
"booked" : false,
"phone_number" : "919191919191",
"location"
浏览 2提问于2020-10-25得票数 0
我试图添加到我的卡夫卡连接。
首先，我验证了我的配置
放置
{
"name": "postgres-kafkaconnector",
"connector.class": "io.debezium.connector.postgresql.PostgresConnector",
"tasks.max": "1",
"database.hostname": "example.com",
"database.port"
浏览 11提问于2022-01-29得票数 0
回答已采纳
我有两个运行在不同机器上的ActiveMQ Artemis代理，组成了一个简单的集群。我正在使用一个Java应用程序(非常基础)来产生和使用消息来分析集群的行为。Java代码如下： public void runExample() throws Exception {
InitialContext initialContext = null;
Connection connectionA = null;
try {
Properties properties = new Properties();
properties.put(
浏览 86提问于2020-07-11得票数 1
回答已采纳
我想通过从MarkLogic数据库中获取数据来创建Jasper报告。不幸的是，Jasper数据库没有JDBC驱动程序，所以有人帮我在Jasper服务器上创建MarkLogic JDBC或JNDI连接。
浏览 0提问于2016-03-30得票数 0
我尝试通过PySpark在HBase中创建Kafka数据摄取。目前，我尝试使用HappyBase将数据从卡夫卡插入到Hbase中，但是速度非常慢。我认为批量加载也使用HappyBase不会显著提高性能。下面是当前的源代码。我需要达到尽可能高的性能。你有什么想法吗？也许是saveAsNewAPIHadoopDataset或其他任何解决方案？
def SaveToHBase(rdd):
print("=====Pull from Stream=====")
if not rdd.isEmpty():
print(len(rdd.collect())
浏览 18提问于2019-03-25得票数 0
将新表添加到Postgres连接器的步骤应该是什么？我的连接器正在跟踪两个表(table1和table2)，我想添加另一个表(table3)，这个表已经存在，并且在我的数据库中有数据。 这是我的当前配置： {
"config": {
"connector.class": "io.debezium.connector.postgresql.PostgresConnector",
"database.dbname": "db_name",
"database.hostname"
浏览 62提问于2021-04-19得票数 2
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
我使用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
回答已采纳
我使用hdfs连接集群，就像在分布式模式下一样。
我设定rotate.interval.ms为1小时，offset.flush.interval.ms为1分钟。
在我的例子中，我认为当一个带有第一个记录时间戳的时间间隔为一个小时的新记录出现时，文件就会被提交；偏移量将每分钟刷新一次。
但是，当文件仍然打开时，我想知道重新启动集群时会发生什么。我是说，在下面的情况下会发生什么？
该文件是以带有“15:37”时间戳的记录开始打开的。(抵销10)
10分钟后，kafka连接集群重新启动。
(我认为步骤1的文件将被丢弃在内存中，而不是提交给hdfs)
当新员工开始工作时，“新打开的文件
浏览 3提问于2021-12-20得票数 0
回答已采纳
1回答
卡夫卡连接器中有可能为单个接收器连接器提供多个转换器吗？例如，我们有一个用例，在该用例中，我们以格式A接收来自主题的数据，但希望将其流到两个位置，一个是格式A，另一个是格式B。在一个连接器中可以做到这一点吗？
浏览 1提问于2017-10-12得票数 0
回答已采纳
嗨，我正在使用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
我想在创建时在我的所有主题中使用自定义复制因子。我正在运行7节点集群，并且我想将5设置为我所有主题的复制因子。
浏览 13提问于2019-12-20得票数 0
我正在尝试将一个postgreql (它是源)事件日志汇到一个已经创建和配置的kafka汇流云上。
FYI，我使用quay.io/debezium/connect:1.9停靠映像作为我的kafka连接服务器，使用aws数据库作为源，使用kafka汇合云主题作为接收器。
我知道属性中有CONNECT_TOPIC_CREATION_ENABLE=false = topic.creation.enable: false这样的参数可以阻止自动创建kafka主题(因为它在我的合流云代理中是不允许的)，但是我在哪里指定主题目的地名称呢？
浏览 4提问于2022-05-25得票数 0
回答已采纳
我有一个运行的debezium设置，用于做MySQL的疾病预防控制中心。现在，我想为另一个MySQL服务器再创建一个MySQL连接器。但是我不想要现有数据的快照，我希望从特定的文件和位置启动debezium新连接器。
我读了一些来自堆栈溢出的问题，他们告诉我手动将记录插入到connect-offsets主题中。但是，如果我这样做，在测试服务器上的现有安装程序上会发生什么情况，我尝试设置上面的解决方案，但它没有工作。
kafka-console-producer --broker-list localhost:9092 --topic connect-offsets
>{"file
浏览 3提问于2019-12-30得票数 1
1回答
我们目前正在尝试使用Debezium来捕获Postgres数据库中4个表的更改。我们目前知道，对于这个用例，我们可以使用kafka-streams应用程序为KTable连接/聚合表，但是我们希望保持kafka流拓扑的简单性，所以我们的想法是使用来自Postgres的物化视图并捕获它的变化。
是否有可能做到这一点，如果是的话，我们应该如何配置它？
卡夫卡连接源配置：
{
"name": "campaign-db-source-connector",
"config": {
"connector.class": "
浏览 2提问于2019-10-24得票数 2
回答已采纳
我一直在尝试使用以下命令/bin connect-standalone.properties config/connect-standalone.properties postgres.sproperties从postgres sql获取数据到kafka主题，但我遇到了几个问题，以下是我的postgres.properties文件的内容： name=cdc_demo
connector.class=io.debezium.connector.postgresql.PostgresConnector
tasks.max=1
plugin.name=decoderbufs
slot.name=d
浏览 165提问于2021-04-07得票数 4
回答已采纳
我已经使用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
回答已采纳
我使用sql-server kafka-connect和debezium来监视sql server数据库，但是当我发布并运行我的工作程序时，主题已经用名称{server_name}.{schema_name}.{table_name}和默认的partitions=1 & replication=1创建了，即使我在"bootstrap.servers“参数中指定了两个代理。如何手动更改表主题的分区和复制，或者在worker/connector配置中预先指定？此外，不同的主题可能有不同的分区和复制。
浏览 0提问于2019-12-30得票数 2
我使用Debezium MySql连接器将数据库更改事件从MySql数据库流式传输到Kafka。我需要将特定的转换应用于某些指定表(而不是其他表)中的记录。有没有一种只使用Kafka Connect单消息转换(没有Kafka Streams或KSQL)的方法？我甚至不介意写一个自定义的SMT。但我找不到如何为消息指定要应用SMT的表/主题。谢谢。 在简短的调查之后，我决定使用KSQL。感谢大家的回答
浏览 10提问于2019-04-11得票数 1
Kafka接收器连接器提供3 insert.mode ..but，我需要更新或插入功能在一起。任何人都能帮助我们实现这一目标。
浏览 4提问于2021-12-20得票数 0
有没有办法从kafka主题中删除一条记录？我知道有脚本kafka- delete -records.sh可以删除指定主题和分区上指定偏移量之前的记录，但我希望能够删除指定偏移量上的记录。有没有办法做到这一点？
这不是在Java上，而是在kafka的裸实例上。
浏览 9提问于2020-02-13得票数 1
回答已采纳
因此，我正在阅读有关连接器1的文档，并试图找出流和接收器连接器2之间的关系。
源连接器3有一个名为"table.whitelist“的属性，据我所知，该属性告诉Debezium只将这些表复制到ksqldb。我在这里的解释也是，CDC也用来将那些源表上发生的更改与ksqldb同步，但没有提到。
但是，单独的流和接收器连接器之间的关系呢？没有像"stream.whitelist“这样的属性。这是否真的意味着所有的流都会被发送到所有的连接器？
例如，我只想从流str1向连接器con1发送数据，只向con2发送流str2。这有可能吗？
浏览 3提问于2022-08-07得票数 0
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
回答已采纳
1回答
我需要在不同的数据库上使用两个完全相同的表(位置也不同)才能在同一主题上发布。Kafka JDBC连接器没有解释它是如何管理高水印的，所以我们想检查一下这个场景中的最佳实践是什么? 1.我们是否可以将两个单独的JDBC连接器发布到单独的主题2。我们是否可以保持两个单独的JDBC连接器发布到同一个主题。
如果我们选择选项2，那么Kafka连接器是如何在消息同时到达表的情况下管理的呢？如何管理不同的数据库时区？
浏览 0提问于2020-04-06得票数 0
回答已采纳
从Kafka connect中删除源连接器后，为该连接器保存的偏移量仍然存在于Kafka中。当具有相同名称的相同连接器再次启动时，它将从上次保存的偏移量开始处理数据。更改连接器的名称不是一个解决方案，因为它使得连接器提交很难自动化。 是否有解决此问题的方法(重命名源连接器不是一个选项)
浏览 77提问于2021-06-17得票数 2
回答已采纳
1回答
我刚刚替换了mysql连接器jar 3.1.12到5.1.27。并得到错误
您需要将Statement.RETURN_GENERATED_KEYS指定为Statement.executeUpdate()或Connection.prepareStatement()。
我找到了我该用的解决方案
PreparedStatement ps = connection.prepareStatement(SQL, Statement.RETURN_GENERATED_KEYS);
相反，
PreparedStatement ps = connection.prepareStatement(SQL);
浏览 0提问于2013-11-21得票数 1
我正在使用Confluent社区平台中的Kafka来保持MySQL数据库的同步。源和汇是MySQL数据库。它没有起作用。
在我的情况下，有一些问题：
在同一台服务器中的其他数据库中有表，我不想将它们读入Kafka，但是Kafka继续尝试读取其他数据库。
我希望在源连接器和Sink连接器中都使用org.apache.kafka.connect.json.JsonConverter，但是接收器连接器无法正确插入。
我想同步几个数据库，不同数据库中的表可能具有相同的表名，如何避免表名冲突和接收器连接器正确路由卡夫卡主题以将数据插入正确的数据库？
Kafka JDBC Source
浏览 0提问于2019-02-19得票数 0
我是卡夫卡和卡夫卡连接世界的新手。我试图使用Kafka (在MSK上)、Kafka (使用PostgreSQL的Debezium连接器)和一个RDS实例来实现CDC。Kafka运行在部署在AWS中的集群中的K8吊舱中。
在深入研究所使用的配置细节之前，我将尝试总结一下这个问题：
一旦连接器启动，它就会像预期的那样向主题发送消息--我们对表(创建、更新、删除)做了任何更改，不会向主题发送任何消息。我们希望看到有关对表所做更改的消息.
我的连接器配置如下：
{
"connector.class": "io.debezium.connector.postgresql.
浏览 0提问于2021-07-09得票数 0
2回答
我知道如何删除卡夫卡连接器，正如这里提到的，
但我不确定它是否也删除/删除特定连接器相关的配置，补偿和状态从*.sorage.topic为该工人？
For例如：可以说，我删除了一个连接器名为“连接器-ABC-1.0.0”的连接器，并使用以下配置启动了Kafka。
offset.storage.topic=<topic.name>.internal.offsets
config.storage.topic=<topic.name>.internal.configs
status.storage.topic=<topic.name>.internal.statu
浏览 0提问于2019-01-15得票数 4
回答已采纳
我使用的是带有MSK的Debezium MySQL，设置非常简单。与极光( MySQL )的连接测试正常。Kafka主题创建，列表都可以。 然而，当我运行连接器时，在滚动了大量信息之后，我得到了 WARN [Producer clientId=xxx] Error while fetching metadata with correlation id 1 : {xxx.xxx=INVALID_REP
LICATION_FACTOR} (org.apache.kafka.clients.NetworkClient:1100) 他们中的许多人不断出现，并且连接器不能正常工作。
浏览 252提问于2021-05-02得票数 1
回答已采纳
我使用postgres配置了debezium，如下代码所示，当我启动我的spring引导应用程序时，a get an error Creation of replication slot failed @Bean
public io.debezium.config.Configuration connector() {
return io.debezium.config.Configuration.create()
.with(EmbeddedEngine.CONNECTOR_CLASS, PostgresConnector.class)
浏览 902提问于2021-04-02得票数 5
我正在创建一个CDC Postgres.source --> Kafka / Debezium --> Postgres.sink。 源主题创建得很好，但只有在表有数据的情况下才能创建。有没有办法在没有数据的情况下实例化所有的主题？因为我想用maven命令下载所有AVRO模式： mvn schema-registry:download 我的配置： {
"name": "postgres-source",
"config": {
"connector.class":"io.debezium.co
浏览 20提问于2021-07-30得票数 0
1回答
目标是: MySQL -> Kafka -> MySQL。接收器目标应与生产环境保持同步。
插入和删除记录是很好的，但是我遇到了模式更改的问题，例如删除的列。更改不会复制到接收器目标。
我的消息来源：
{
"name": "hub-connector",
"config": {
"connector.class": "io.debezium.connector.mysql.MySqlConnector",
"database.hostname
浏览 22提问于2021-06-01得票数 0
到目前为止，我使用kafka spring在this blog上生成了一条主题消息。 我要传递的消息只是名称，现在我想流过这个主题，并添加增量值作为ID和名称，并将其存储在OutputTopic上，现在，我想将数据存储到cassandra。 我在cassandra中的表结构如下： CREATE TABLE emp(
emp_id int PRIMARY KEY,
emp_name text,
) 输出主题上的数据应该是哪种格式，以便我可以轻松地将其存储在cassandra表中？ 如何实现上述功能？
浏览 12提问于2021-08-25得票数 1
回答已采纳
1回答
几天来，我一直在努力将来自Mqtt Source Connector的ByteArray值转换为字符串。我们的独立配置有以下参数： 我们的独立属性文件如下所示： # The converters specify the format of data in Kafka and how to translate it into Connect data. Every Connect user will
# need to configure these based on the format they want their data in when loaded from or stored i
浏览 29提问于2021-09-23得票数 0
Q1)下面是我在为MySQL源代码创建卡夫卡连接器时使用的配置。
{
"connector.class": "io.debezium.connector.mysql.MySqlConnector",
"snapshot.locking.mode": "minimal",
"database.user": "cdc_user",
"tasks.max": "3",
"database.history.kafka.bootstrap.serve
浏览 4提问于2022-01-05得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
