Kafka connect jdbc源返回0条记录
Kafka Connect JDBC源是Kafka Connect的一个插件，用于从关系型数据库中读取数据并将其发送到Kafka集群中。当Kafka Connect JDBC源返回0条记录时，可能有以下几个原因：
- 数据库连接配置错误：请确保已正确配置数据库连接参数，包括数据库地址、端口、用户名、密码等。可以参考腾讯云的云数据库MySQL产品（https://cloud.tencent.com/product/cdb_mysql）来管理和配置MySQL数据库。
- 数据库中没有符合条件的数据：请检查数据库中是否存在符合Kafka Connect JDBC源配置的查询条件的数据。可以使用腾讯云的云数据库MySQL产品提供的数据管理工具，如phpMyAdmin（https://cloud.tencent.com/document/product/236/3130）来执行SQL查询语句，确认是否存在符合条件的数据。
- 查询条件配置错误：请仔细检查Kafka Connect JDBC源的配置文件，确保查询条件的语法正确，并且与数据库中的数据匹配。可以参考腾讯云的Kafka Connect产品（https://cloud.tencent.com/product/ckafka-connect）来了解如何正确配置Kafka Connect JDBC源。
- 数据库访问权限不足：请确保Kafka Connect JDBC源所使用的数据库用户具有足够的权限来执行查询操作。可以参考腾讯云的云数据库MySQL产品提供的权限管理功能，为数据库用户分配合适的权限（https://cloud.tencent.com/document/product/236/3131）。
如果以上解决方法无效，建议检查Kafka Connect JDBC源的日志文件，查看是否有相关的错误或警告信息。根据日志中的提示，可以进一步定位和解决问题。同时，也可以参考腾讯云的技术文档和社区论坛，寻求更多的帮助和支持。
相关·内容
1回答
Kafka connect jdbc源返回0条记录
mysql、jdbc、apache-kafka、apache-kafka-connect
尽管news表有超过6500万条记录，但我在Kafka主题中看不到任何记录。"name": "news_fetcher", "connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector`news` (io.confluent.connect.jdbc<
浏览 18提问于2021-06-06得票数 0
1回答
java包中接收器连接器的实现
java、apache-kafka、apache-kafka-connect
我已经启动了zookeeper，kafka服务器，kafka生产者和kafka消费者，我已经把从confluent下载的jdbc sql连接器jar放在路径中，我已经在connect-standalone<init>(Reflections.java:140)
at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader<init>(DelegatingCl
浏览 21提问于2020-10-28得票数 0
1回答
如何使用kafka连接JDBC接收器和使用python的源
apache-kafka、apache-kafka-connect、kafka-python
我正在使用kafka-python，并且能够在本地直播。 计算出连接器将处理多个设备。有人能给我推荐一种在python中使用连接器实现它的方法吗？
浏览 28提问于2021-10-07得票数 1
回答已采纳
1回答
融合JDBC与Apache Kafka连接
apache-kafka、apache-kafka-connect、confluent-platform
Apache Kafka集群中可以使用Confluent Kafka JDBC连接吗？我正在尝试使用Confluent JDBC connect在apache kafka集群上安装和配置它，用于连接到mssql数据库的源属性。
浏览 6提问于2019-10-08得票数 0
1回答
使用KAFKA作为热库，MySQL作为冷库
mysql、apache-kafka
我想每秒向KAFKA中插入大约500k的数据，然后将它们与每秒仅支持40k插入/更新的MySQL数据库同步。因此，为了实现我的目标，我想使用KAFKA作为热存储，因为我需要尽可能快地使用数据，并与多个服务共享它们，并快速进行更新，因为它不能单独使用MySQL (我想将其用作冷存储，以尽可能长地存储数据并存档更改
浏览 0提问于2019-06-20得票数 0
1回答
Confluent JDBC连接器，其中保存有关上次读取ID和时间戳的信息
jdbc、apache-kafka、apache-kafka-connect、confluent-platform
我正在我的本地机器上运行Confluent JDBC连接器，并试图找出它存储有关上次读取ID和时间戳的信息的位置。根据https://www.confluent.io/blog/kafka-connect-deep-dive-jdbc-source-connector/#starting-table-capture我的连接器： {
"connector.class": "io.confluent.connect.<em
浏览 10提问于2021-01-27得票数 0
3回答
不工作json模式的Kafka jdbc接收器连接器
json、jdbc、apache-kafka、apache-kafka-connect
使用最新的kafka和汇流jdbc接收器连接器。msgschema" "payload": { "msg": "hi"}org.apache.kafka.connect.errors.DataException
浏览 1提问于2018-02-28得票数 2
回答已采纳
2回答
sqlite3的Kafka JDBC源连接器时间戳模式失败
sqlite、apache-kafka、apache-kafka-connect、confluent-platform
Kafka连接失败，错误如下：CURRENT_TIMESTAMP' java.sql.SQLException: Error parsing\E(\p{Nd}++)配置：
name=test-query-sqlite-jd
浏览 1提问于2019-02-04得票数 1
1回答
如何执行JDBC Kafka Connector jar
jdbc、apache-kafka、apache-kafka-connect
我克隆了，但我在理解如何执行它时遇到了问题。
浏览 2提问于2018-05-11得票数 0
2回答
Log4j2 -为包设置日志级别，然后设置子包
java、apache、logging、log4j2
除了卡夫卡( Kafka )，它产生了太多的警告，所以我尝试了如下：log4j.logger.org.apache=WARNlog4j.logger.org.apache.kafka.common.config=ERROR
log4j.appender.console=org.apache.log4j.ConsoleAppender但是log4j.logger.org.apache.kafka.common.config=ERROR doen似乎什么也不做，因为我
浏览 3提问于2017-12-20得票数 3
回答已采纳
1回答
我的生产者(SQL Server)打开了，Kafka关闭了。如何重新处理发往kafka的消息？
apache-kafka、apache-kafka-connect
我正在使用Debezium SQL Server Source connector通过CDC将数据推送到Kafka。SQL Server表中的数据是连续插入的。当Kafka宕机时，数据还会插入到该表中吗？如果是这样，当我的Kafka打开时，如何获得这些记录？
浏览 13提问于2020-05-22得票数 0
回答已采纳
2回答
汇合的Kafka流-找不到类io.confluent.connect.avro.ConnectDefault
java、apache-kafka-streams、apache-kafka-connect、confluent-platform、confluent-schema-registry
我使用的是带有查询模式的jdbc源连接器，似乎没有指定表名的情况下，在模式注册表中为记录键和记录值注册的模式具有空的模式名称，并被分配了默认名称"ConnectDefault“，如Confluent的AvroData我是否遗漏了一个名为ConnectDefault的类，或者我是否可以在源连接器中的某处指定一个不带名称空间的模式名称？Connect配置：connector.class=io.confluent.connect.j
浏览 4提问于2017-11-03得票数 2
1回答
Kafka Connect JDBC源连接器是幂等的吗？
apache-kafka、apache-kafka-connect、confluent-platform
那么，这个连接器能保证它不会在代理崩溃或任何可能发生的情况下产生重复的记录吗？我们是否必须像使用any other Kafka Producer (enable.idempotence: true)一样配置一些东西来获得补偿？
浏览 10提问于2019-06-26得票数 3
回答已采纳
1回答
如何在JDBC Source Connector中将偏移量设置为开始，以便在Kafka中从MySQL表中获取所有数据
mysql、jdbc、apache-kafka、apache-kafka-connect
我使用Kafka Connect添加了JDBC Source Connector，Kafka Connect从MySQL表中获取数据。{"connector.class": "io.aiven.conn
浏览 4提问于2019-11-04得票数 0
1回答
kafka-connect jdbc分布式模式
apache-kafka、apache-kafka-connect、confluent-platform
我们正在使用increment+timestamp模式下的JDBC源连接器构建Kafka-connect应用程序。我们尝试了独立模式，它可以像预期的那样工作。现在，我们想切换到分布式模式。当我们有一个单一的Hive表作为源时，任务将如何在工作人员之间分配？
我们面临的问题是，当我们在多个实例中运行应用程序时，它会查询每个实例的表，并再次获取相同的行。并行在这种情况下会起作用吗？
浏览 4提问于2018-08-29得票数 0
1回答
JDBC源连接器和宿连接器是否需要Confluent？
java、apache-kafka、apache-kafka-connect、confluent-platform
我是否需要专门为Kafka JDBC源和宿连接器使用Confluent，或者我可以使用默认的apache Kafka实现吗？我尝试使用JDBC源配置作为worker属性来启动connect-standalone，但得到了以下异常： Failed to find any class that implements Connectorand which name matches io.confluent.connect.jdbc.Jdbc
浏览 8提问于2021-06-14得票数 0
回答已采纳
1回答
使用kafka可以使用文件源作为输入，使用jdbc-接收器作为输出吗？
jdbc、apache-kafka、apache-kafka-connect、confluent-platform
我目前正在做一个Kafka项目，我的问题是我能够用文件源连接器读取一个文件，并将数据存储到一个主题中。:194)at org.apache.kafka.connect.runtime.WorkerTask.run:63)
at io.confluent.connect.jdbc.sink.Buffered
浏览 1提问于2019-06-03得票数 1
回答已采纳
1回答
从Kafka提要读取Server
sql-server、apache-kafka、apache-kafka-connect
我需要从一个Kafka提要中读取Server数据库，并且我很难找到关于如何做到这一点的任何细节。我意识到这可能很简单，但我只找到了从SQL输入卡夫卡的东西
浏览 1提问于2018-11-05得票数 8
1回答
如何在kafka连接jdbc中重写key.serializer
apache-kafka、apache-kafka-connect
我正在使用kafka源连接器对kafka进行mysql连接。一切都很好。现在我需要传递key.serializer和value.serializer来加密数据，就像在上显示的那样。POST API启动源连接器 "name": "jdbc-source-connector-2",
"config
浏览 1提问于2020-01-07得票数 0
回答已采纳
腾讯云开发者
