我们正在尝试使用Confluent JDBC-Source connector将数据从数据库表复制到Kafka中。问题是，该表中的数据每晚恰好更新一次，因此我们希望在表更新后复制最新的数据，例如，我们希望连接器在每天早上7点运行。这有可能吗？documentation只显示轮询间隔属性，如果我们将poll.interval设置为24小时，我们只能使用该属性，但是我们必须在早上7点启动连接器，这并<e
浏览 26提问于2019-02-18得票数 0
回答已采纳
1回答
我想使用Confluent的JDBC源连接器将数据从Server表检索到Kafka。mode=incrementing当我运行这个连接器时
浏览 4提问于2020-09-02得票数 2
回答已采纳
1回答
有没有办法通过jdbc连接器将数据从KSQL导出到mysql表中？？ 我了解了如何使用KSQL将mysql表数据导入到Kafka集群中。但这不是我想要的。cp-ksql-server:5.3.1
confluentinc/cp-ksql-cli:5.3.1 https://www.confluent.io/hub/confluentinc/kafka-co
浏览 44提问于2020-03-17得票数 0
我创建了一个本地数据库，用于在MySQL上进行测试。当我试图从数据库中读取数据时，它读得很好。当我在连接器配置中使用SQL查询时，它只是在运行，而不是从数据库读取任何数据。你知道这是什么原因吗？以下是我的连接器配置：acks=0 key.converter=io
浏览 0提问于2018-11-14得票数 1
我想在confluent上使用JDBC连接器。当我开始与合流CLI连接时，它就不起作用了。jdbc:oracle:thin:@10.10.10.10:1954/MYSERVICE
./bin/connect-distributed etc/schema-registry/connect-avro-distributed.properties
但是上面的代码运行<
浏览 12提问于2020-04-01得票数 3
回答已采纳
我们已经使用jdbc独立连接器成功地使用了MySQL - kafka数据摄取，但现在在分布式模式(作为kafka connect服务)中使用同样的连接器时遇到了问题。用于工作正常的独立连接器的命令-
/usr/bin/connect-standalone /etc/kafka/connect-standalone.properties /etc/kafka-connect-jdbc<
浏览 1提问于2018-11-15得票数 2
1回答
我对Confluent Community License和Confluent connectors感到有点困惑。根据的说法，它只适用于一些合流连接器，在下面的图表中，它列出了Apache2.0许可下的社区连接器。然后，如果你搜索，你可以看到支持Confluent的Kafka Connect HDFS连接器(在写这个问题的时候，版本是: confluentinc/kafka-connect-hdfs:5.4。连接器的页面如下：
然而，如果你点
浏览 4提问于2020-02-07得票数 0
我正在尝试部署一个独立的连接作业来从mssql服务器流传输，但是我遇到了一个问题(Kafka-Connect是我的Ambari部署的一部分，而不是docker)。这是我正在使用的属性文件：connector.class=io.confluent.connect.jdbc.JdbcSourceConnectorconnection.user=uetasks.max=1
connection.url=j
浏览 1提问于2018-05-29得票数 1
--我用卡夫卡，卡夫卡-连接(图片:confluentinc/cp connect)所以..。我的问题是
在拼装(放入容器)之后，如果我想连接一些连接器(‘.
浏览 26提问于2022-05-20得票数 0
我使用的是confluent平台JDBC连接器，它是从mysql到kafka消费者的流式数据。通过应用程序将数据插入另一个数据库以进行报告。这里的问题是，它只是在某个时间间隔内一次又一次地流式传输所有数据。实际上，A只想要那些新插入的数据或对以前记录的任何更新。{
"name":"mysql-conn
浏览 0提问于2021-06-14得票数 0
我对Kafka非常陌生，我正在尝试使用MySQL源连接器和弹性搜索+弹性搜索接收器连接器来启动和运行一个简单的kafka连接系统；用于基本数据流目的。我遵循的步骤&它的第2部分(我已经通过在源端有一个简单的生成器来验证ES的工作。)
除了MySQL源连接器之外，一切都按预期配置和工作。在我尝试所有这些的VM中，上没有安装MySQL服务器。在本教程的DBMS部分，我使用一个客户端来创建/修改和播放表。因此，在<
浏览 2提问于2019-01-29得票数 0
回答已采纳
如果我的问题到处都是，很抱歉，但我是Apache Kafka的新手，目前我正在尝试使用Windows操作系统将Teradata表(在VM上)中的数据导入到Kafka中。到目前为止，我已经完成了以下工作：1-我遇到的大多数帖子都使用</
浏览 0提问于2020-10-28得票数 2
1回答
我需要使用confluent/kafka将Server数据库从on位置迁移到GoogleCloud。": "io.confluent.connect.avro.AvroConverter", ...我需要插入数据到target_dbname数据库jdbc同步连接器有以下配置 "name": "mssql_trg
浏览 5提问于2020-12-11得票数 1
我正在尝试探索KafkaConsumer是否可以在消息到达某个主题时接收消息，而不是在特定的时间间隔轮询。我知道Kafka是消费者端的一种拉取机制，由于我不确定消息何时到达，也不确定轮询时间间隔的最佳值，是否可以达到上述要求？
浏览 0提问于2018-08-07得票数 0
我正在尝试使用JDBC连接器将数据写入雪花，但我一直收到下面的错误，提示在数据库中找不到表(由于雪花不支持自动创建，所以我禁用了它)。test_table" (io.confluent.connect.jdbc.dialect.GenericDatabaseDialect:575)at io.confluent.connect.jdbc.sink.BufferedRecords.add(Buffer
浏览 1提问于2021-11-08得票数 2
我试图用基于Kafka的汇合式在几个MySQL数据库之间同步数据。我在源连接器配置中使用了"bulk“模式，因为主键类型是varchar，所以不能使用增量模式。很好，但我有两个问题：
同步数据需要相当长的时间。在我的例子中，将表与3~4k行同步大约需要2~4分钟。我可以理解，使用大容量模式可能需要更多
浏览 5提问于2017-09-19得票数 2
回答已采纳
我使用kafka-connect-jdbc-4.0.0.jar和PostgreSQL9.4-1206-jdbc41.jar{}
我已经在postgresql数据库("PostgreSQL 9.6.9")上使用
浏览 1提问于2019-01-14得票数 1
回答已采纳
这是我正在进行的配置，但即使查询在DB服务器上生成记录，它也无法工作。 "connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector", "mode": "bulk",
"connection.url": "jdbc:mysql://my
浏览 4提问于2019-10-18得票数 2
回答已采纳
2回答
我需要编写一些索引作业，以便每天运行一次，将我们的Oracle数据库表和索引查询到ElasticSearch中。有些表首先索引，另一些表则是下一个索引，因为存在表依赖关系。但是，在索引的过程中，我需要增强到ES索引的字段，并记录到Oracle数据库表的作业状态，甚至可能是索引过程成功/失败的记录。
我可以使用弹性搜索插件JDBC-River。
浏览 1提问于2014-01-30得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
云直播
腾讯会议活动推荐
腾讯云开发者
