腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
2
回答
将数据从
kafka
复制到mysql,不能用DOcker和Debezium连接到DOcker。
mysql
、
apache-kafka-connect
、
debezium
{ "config" : {{“io.confluent.
con
浏览 0
提问于2019-11-06
得票数 0
1
回答
kafka
JDBC
Sink Connector是否跟踪加载到目标数据库的数据?
sql-server
、
jdbc
、
apache-kafka
、
apache-kafka-connect
、
confluent-platform
我使用的是
kafka
jdbc
接收器
连接器
,它从主题插入数据到SQL Server数据库。由于mssql中的某些
问题
,
连接器
已停止,并出现错误: Caused by: org.apache.
kafka
.
connect
.errors.ConnectException: com.microsoft.sqlserver.
jdbc
.SQLServerExceptionError: "
connect
timed ou
浏览 4
提问于2020-04-03
得票数 1
1
回答
如何在
kafka
接收器
连接器
中设置特定表?
apache-kafka
、
apache-kafka-connect
、
confluent-platform
我使用的是confluent
kafka
连接器
。我想将数据插入到
接收器
连接器
中的特定表TB_TEST_
KAFKA
中。我已经创建了这个表。 auto.create=false。我不知道
接收器
连接器
的属性、表名、键。我正在尝试插入到特定表TB_TEST_
KAFKA
中, connector.class=io.confluent.
connect
.
jdbc
.JdbcSinkConnector errors.log.incl
浏览 51
提问于2021-08-10
得票数 0
1
回答
为
Kafka
Connect
消费群申请配额
apache-kafka
、
apache-kafka-connect
我让
Kafka
Connect
JDBC
接收器
连接器
写入不同的数据库,我想限制到一个数据库的流量。
Kafka
quotas功能可以为客户端ID设置consumer_byte_rate配额,但
Kafka
Connect
客户端ID看起来像consumer-1234,并动态分配给
连接器
。因此,如果我的
接收器
连接器
被重新平衡,它将被分配所有新的客户端ID。我尝试使用我的
接收器
连接器
浏览 16
提问于2019-12-18
得票数 0
1
回答
如何将
kafka
-
connect
-
jdbc
-5.5.0.jar添加到Debezium/
connect
apache-kafka
、
apache-kafka-connect
、
cdc
、
debezium
、
confluent-platform
我已经从confluent下载了
kafka
-
connect
-
jdbc
-5.5.0.jar文件到我的本地机器中,我想知道如何将这个jar添加到plugin.path=/
kafka
/
connect
中。我正在尝试将数据汇聚到mysql服务器,所以我使用了"connector.class":" io.confluent.
connect
.
jdbc
.JdbcSinkConnector“,但我面对的是"error_code&
浏览 22
提问于2020-06-19
得票数 0
回答已采纳
1
回答
如何使用
kafka
连接
JDBC
接收器
和使用python的源
apache-kafka
、
apache-kafka-connect
、
kafka-python
我正在使用
kafka
-python,并且能够在本地直播。 计算出
连接器
将处理多个设备。有人能给我推荐一种在python中使用
连接器
实现它的方法吗?
浏览 28
提问于2021-10-07
得票数 1
回答已采纳
1
回答
即使安装了JdbcSinkConnector,
Kafka
connect
也无法找到它
apache-kafka
、
apache-kafka-connect
、
confluent-platform
我已经在我的
kafka
connect
连接器
中安装了运行confluent-hub install --no-prompt confluentinc/
kafka
-
connect
-
jdbc
:10.2.5的
JDBC
连接器
,但是当我尝试使用实现一个新的
接收器
时,我遇到了以下错误:找不到任何实现
连接器
并且名称与io.confluent.
connect
.
jdbc
.JdbcSinkC
浏览 7
提问于2021-10-30
得票数 0
1
回答
如何使用FME处理
Kafka
JDBC
接收器
apache-kafka
、
apache-kafka-connect
、
confluent-platform
、
fme
我已经设置了
Kafka
JDBC
接收器
连接器
,在那里它将使用来自
kafka
生产者api的数据,但是我想设置FME来处理数据端,并将其接收到数据库,在那里它将与GIS (地理信息系统)交互,它将流式传输空间数据我对FME了解不多,是否有任何信息/文档,或者是否有人知道并可以解释如何使用
Kafka
JDBC
Sink Connector设置FME谢谢
浏览 16
提问于2021-02-02
得票数 0
2
回答
将数据从
kafka
传输到oracle db的最佳方式是什么?
apache-kafka
、
apache-kafka-streams
、
apache-kafka-connect
、
spring-kafka
我正在尝试找到一种解决方案,将数据从
Kafka
直接传输到Oracle。最有效的解决方案是什么?
浏览 32
提问于2018-01-03
得票数 1
1
回答
防止
Kafka
JDBC
接收器
记录__
connect
_partition和__
connect
_offset
jdbc
、
apache-kafka
、
apache-kafka-connect
、
confluent-platform
我在
Kafka
中有一个日志压缩的主题,它是通过
JDBC
接收器
连接器
写入Postgres的。尽管我在
连接器
上设置了mode=upsert,但它仍然在
接收器
数据库中为每个值添加了唯一行,因为它记录了每行的主题偏移量(__
connect
_offset)和分区(__
connect
_partition如何禁止
JDBC
接收器
记录主题信息(我并不关心这些信息)?添加一个只获取我的数据列的fields.whitelist并没有成功阻
浏览 0
提问于2018-10-02
得票数 2
1
回答
卡夫卡
连接器
的健康检查
apache-kafka-connect
、
health-monitoring
我在生产中有几个
Kafka
connectors。有时,这些
连接器
中的一个会随错误消息而死: ERROR WorkerSinkTask{id=
jdbc
-
接收器
-0}任务抛出了一个未恢复的不可恢复的异常org.apache.
kafka
.common.errors.WakeupException错误(org.apache.
kafka
.
connect
.runtime.WorkerTask:173) {id=
jdbc
-
接收器
-0}任务被终止
浏览 0
提问于2018-07-17
得票数 2
3
回答
无法使用汇合性CLI :java.sql.SQLException设置CLASSPATH :找不到适合
jdbc
:oracle的驱动程序
oracle
、
jdbc
、
apache-kafka
、
apache-kafka-connect
、
confluent-platform
我想在confluent上使用
JDBC
连接器
。当我开始与合流CLI连接时,它就不起作用了。
jdbc
:oracle:thin:@10.10.10.10:1954/MYSERVICE .export CLASSPATH=/home/my_confluent/confluent-5.4.1/share/java/
kafka
-
connect
浏览 12
提问于2020-04-01
得票数 3
回答已采纳
2
回答
Confluent Sink
连接器
-到多个数据库目标的Sink
apache-kafka
、
apache-kafka-connect
、
confluent-platform
如果我需要将相同的数据从一个主题复制到具有不同in的多个数据库中,我是否需要创建多个
接收器
连接器
,或者我可以通过connection.url或其他方式指定多个目的地。 非常感谢您的帮助
浏览 41
提问于2020-09-21
得票数 0
回答已采纳
1
回答
消费到CSV的
Kafka
流
java
、
apache-kafka
、
kafka-consumer-api
、
apache-kafka-connect
我在java中使用
Kafka
,我使用JSON消息作为字符串,速度是每分钟一百万条消息,我需要拆分字符串,只取一些值,并将其保存到CSV中,以将其加载到数据库中,我如何才能做出这样的事情?
浏览 7
提问于2020-05-20
得票数 0
1
回答
从mysql到mongo数据库的数据调度
问题
mysql
、
mongodb
、
apache-kafka
、
etl
、
data-synchronization
我们正在开发一个SAAS系统,在这个系统中,我们最初使用MySQL作为DB,但随着数据的增长,我们的数据列表变慢了,所以为了解决这个
问题
,我们已经使用了Mongo DB,我们已经在其中存储了准备好的JSON
浏览 14
提问于2020-02-04
得票数 0
1
回答
如何使用
jdbc
连接器
将ksql表数据导出到Mysql表
mysql
、
apache-kafka
、
confluent-platform
、
connector
、
ksqldb
有没有办法通过
jdbc
连接器
将数据从KSQL导出到mysql表中?? 我了解了如何使用KSQL将mysql表数据导入到
Kafka
集群中。但这不是我想要的。host --interactive --tty \ confluentinc/cp-ksql-cli:5.3.1 https://www.confluent.io/hub/confluentinc/
kafka
-
connect
-
jdbc
clickstream-docker.ht
浏览 44
提问于2020-03-17
得票数 0
2
回答
将PostgreSQL数据复制到基图斯/格林梅利?
postgresql
、
replication
、
data-warehouse
、
greenplum
、
citus
在这方面,我有以下
问题
: Postgres逻辑复制会与Citus一起工作吗?Citus是Postgres的扩展,你能把它当作一个普通的Postgres数据库吗?我是否需要将逻辑级别的WAL流到
Kafka
中,然后编写自定义逻辑将其转换为目标数据库上的SQL语句?有什么工具吗?额外的
问题
:是否有人有使用过Citus和Greenplum的经验,特别是他们的SQL限制?我知道CTEs不完全支持相关的子查询和递归的CTE,Greenplum有类似的限制吗?我希望能在这些
问题
上提供任何帮助,我试着在谷歌上搜索,但很少或根本没有关于这个
浏览 0
提问于2021-02-04
得票数 0
2
回答
如何使用
JDBC
接收器
连接器
将表名转换为大写
oracle
、
jdbc
、
apache-kafka-connect
、
confluent-platform
、
debezium
对于源
连接器
,我使用的是Debezium的Postgres
连接器
和汇
连接器
--Confluent的
JDBC
sink
连接器
。如何在
JDBC
接收器
连接器
中动态设置配置,以便不需要在transforms.route.replacement?然后,我收到以下错误: 由: org.apache.
kafka
.
connect
.errors.ConnectException:表“TEST”引起的。下面是我的
JDBC</em
浏览 5
提问于2021-04-01
得票数 1
1
回答
用于处理数据的实时管道,插入PSQL
python
、
sql
、
postgresql
、
apache-kafka
我每天都会收到一些文件,我想在这些文件进来时进行处理,并插入到现有的sql表中(使用postgres)。创建自动管道的最佳方法是什么?任何帮助都是非常感谢的!
浏览 11
提问于2022-01-27
得票数 2
1
回答
向
kafka
连接中添加新的
接收器
配置
apache-kafka
、
apache-kafka-connect
、
confluent-platform
我正忙于学习
kafka
,特别是使用
接收器
连接器
(
jdbc
)将数据从
kafka
主题发送到mysql的下游元素。我已经在这样的Dockerfile文件中,使用
jdbc
连接器
和mysql驱动程序构建了一个由融合式
kafka
连接基映像生成的映像: FROM confluentinc/cp-
kafka
-
connect
-baseRUN confluent-hub install --no-prompt confluen
浏览 3
提问于2020-03-19
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
深入理解Kafka Connect:转换器和序列化
这可能是北半球最暖的Kafka Connect数据管道教程:3
这可能是北半球最暖的Kafka Connect数据管道教程:2
大数据流处理:Flume、Kafka和NiFi对比
读书笔记:《How to Build a Scalable ETL Pipeline with Kafka Connect》
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
云直播
活动推荐
运营活动
广告
关闭
领券