腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(390)
视频
沙龙
1
回答
Kafka
Connect
JDBC
Sink
能否
转
储
原始数据
?
apache-kafka
、
apache-kafka-connect
作为一个基于Java的消费者,我有这个功能,但我正在考虑是否可以使用
Kafka
Connect
来实现这一点。有没有办法在
Connect
配置中做到这一点,或者我是否正在考虑添加额外的处理来更新消息(在这种情况下,Java客户端可能最终会变得更简单)
浏览 12
提问于2021-01-29
得票数 0
回答已采纳
1
回答
如何让Instaclustr
Kafka
Sink
Connector与Avro serialized value to postgres一起工作?
postgresql
、
apache-kafka
、
avro
、
apache-kafka-connect
我有一个关于Avro-serialized value的
Kafka
主题。 我正在尝试设置
JDBC
( postgres )接收器连接器,以便将这些消息
转
储
到postgres表中。"org.apache.
kafka
.common.config.ConfigException: Invalid value io.confluent.
connect
.avro.AvroConverter我的
Sink
.json是 {"name": "post
浏览 30
提问于2020-01-29
得票数 0
1
回答
没有找到带有mysql DB表的
kafka
接收器连接器
mysql
、
apache-kafka
、
apache-kafka-connect
、
confluent-platform
我试图将
kafka
接收器连接器配置到mysql。
Kafka
主题在AVRO格式中有价值,我想将数据
转
储
到mysql。我在说找不到表时出错了(表'airflow.mytopic‘不存在)。配置:"connector.class": "io.confluent.
connect
.
jdbc
.JdbcSinkConnector", "connection.u
浏览 5
提问于2021-12-29
得票数 0
回答已采纳
1
回答
Windows上的
Kafka
Connect
for Oracle安装程序
apache-kafka
、
windows-7
、
apache-kafka-connect
我可以在我的windows7机器上设置
Kafka
服务器/zookeeper。创建了一个.NET应用程序来生产和使用应用程序。 我现在需要oracle来使用生成的主题。我需要一些关于在我的运行在Windows 7上的
Kafka
上设置
Kafka
连接的说明。 请给我一些如何做到这一点的指导。 我对卡夫卡非常陌生。到目前为止,我所做的只是在windows上设置
Kafka
服务器。
浏览 26
提问于2019-06-07
得票数 0
回答已采纳
1
回答
尝试加载
JDBC
接收器连接器时出错
mysql
、
jdbc
、
apache-kafka
、
mysql-connector
这是我的
sink
-mysql.properties文件:connector.class=io.confluent.
connect
.
jdbc
.JdbcSinkConnector/bin/
connect
-standalone etc/schema-registry/
connect
-avro-standalone.properties etc/
kafka
-
connect
-<e
浏览 0
提问于2018-02-01
得票数 1
回答已采纳
1
回答
结构化流媒体:一次阅读多个
Kafka
主题
apache-spark
、
apache-kafka
、
spark-structured-streaming
SchemaConverters.toSqlType(schema).dataType.asInstanceOf[StructType] .readStream .format("
kafka
浏览 0
提问于2020-04-13
得票数 2
1
回答
Kafka
连接
JDBC
Sink
- topics.regex不工作
regex
、
jdbc
、
apache-kafka
、
apache-kafka-connect
、
confluent-platform
我正在使用这个{"config": {
connect
_1 | at io.confluent.
connect
.
jdbc
.
sink
.BufferedRecords.add(BufferedRec
浏览 0
提问于2019-01-30
得票数 0
1
回答
使用
Kafka
jdbc
接收器将数据加载到oracle表中
apache-kafka
、
apache-kafka-connect
我正在尝试使用
JDBC
接收器连接器将数据从
Kafka
加载到Oracle,以复制confluent网站中提到的示例: connector.classto the
JDBC
sink
connector(DbStructure.java:137) at io.confluent.
connect
.
jdbc
.
sink
.DbStructure.createO
浏览 10
提问于2018-02-20
得票数 0
1
回答
如何在
kafka
接收器连接器中设置特定表?
apache-kafka
、
apache-kafka-connect
、
confluent-platform
我正在尝试插入到特定表TB_TEST_
KAFKA
中, connector.class=io.confluent.
connect
.
jdbc
.JdbcSinkConnectorat io.confluent.
connect
.
jdbc
.
sink
.DbStructure.create(DbStructure.java:116)at io.confluent.
connect
浏览 51
提问于2021-08-10
得票数 0
1
回答
PostgreSQL与
Kafka
连接集成问题
postgresql
、
apache-kafka
、
apache-kafka-connect
我正在测试
JDBC
连接器,以将记录从
Kafka
转
储
到PostgreSQL。下面是Connector配置: "name": "
jdbc
-
sink
-postgresql-1", "connector.class": "io.confluent.
connect
.
jdbc
.JdbcSinkConnector&qu
浏览 0
提问于2018-10-07
得票数 0
回答已采纳
1
回答
JDBC
接收器连接器抛出java.sql.BatchUpdateException
apache-kafka
、
teradata
、
apache-kafka-connect
几周前,我创建了一个
Sink
JDBC
。直到日志开始显示这个错误: [2019-06-27 11:35:44,121] WARN Write of 500 records failed, remainingRetries=10 (io.confluent.
connect
.
jdbc
.
sink
.JdbcSinkTaskio.confluent.
connect
.
jdbc
.
sink
.BufferedRecords.flush(BufferedRecords.j
浏览 2
提问于2019-06-27
得票数 0
1
回答
如何通过Flume将文件加载到
Kafka
Producer?
file
、
upload
、
apache-kafka
、
flume
我有一个日志文件,我正在尝试通过Flume代理推送到
Kafka
Producer。我可以直接从我的本地机器将文件加载到
Kafka
producer。但我的用例是使用Flume代理推送到
Kafka
。我已经安装了Flume,并在我的localhost @ 中启动并运行任何帮助都将不胜感激。谢谢!
浏览 3
提问于2015-10-23
得票数 1
1
回答
用KSQL从
Kafka
转
储
表到MariaDB
apache-kafka
、
apache-kafka-connect
、
ksqldb
| at io.confluent.
connect
.
jdbc
.
sink
.RecordValidator.lambda$requiresValue$2(RecordValidator.java:86)
kafka
-
浏览 7
提问于2021-03-08
得票数 0
回答已采纳
1
回答
microsoft sql server的
jdbc
接收器的
kafka
连接。它适用于record_value的多个键,并且对于record_key弹出此错误
sql-server
、
jdbc
、
apache-kafka
、
apache-kafka-connect
、
confluent-platform
我使用的是
kafka
connect
的
jdbc
接收器驱动程序。当我尝试添加两个pk.key字段时,它允许创建具有一个主键的表。(TableDefinitions.java:86) at io.confluent.
connect
.
jdbc
.<
浏览 19
提问于2019-05-01
得票数 1
1
回答
将
JDBC
接收器连接器连接到CrateDB
java
、
docker
、
apache-kafka
、
apache-kafka-connect
、
cratedb
连接器单机版容器的Docker日志: [2020-08-20 10:34:06,430] ERROR WorkerSinkTask{id=
jdbc
-
sink
-connector-0} Task threwan uncaught and unrecoverable exception (org.apache.
kafka
.
connect
.runtime.WorkerTask:179)
浏览 26
提问于2020-08-20
得票数 0
1
回答
无法使用
JDBC
kafka
-接收器-连接器将
kafka
主题数据写入postgres DB
postgresql
、
apache-kafka
、
avro
、
apache-kafka-connect
、
confluent-platform
{ "config" : { at org.apache.
kafk
浏览 3
提问于2021-09-28
得票数 0
2
回答
Kafka
JDBC
Sink
连接器在雪花中找不到表
jdbc
、
apache-kafka
、
snowflake-cloud-data-platform
、
apache-kafka-connect
Executing stage 'TASK_PUT' with class 'org.apache.
kafka
.
connect
.
sink
.SinkTask'.(org.apache.
kafka
.
connect
.runtime.errors.LogReporter:66)at io.con
浏览 1
提问于2021-11-08
得票数 2
1
回答
卡夫卡连接:找不到合适的司机
postgresql
、
apache-kafka
、
apache-kafka-connect
、
confluent-platform
(CachedConnectionProvider.java:68) at io.confluent.
connect
.
jdbc
.
sink
.JdbcSinkTask.put(JdbcSinkTask.java:69) at org.apache.
kafka
.
connect
.runti
浏览 0
提问于2018-06-25
得票数 2
回答已采纳
1
回答
无法使用面临问题的com.mysql.
jdbc
.exceptions.
jdbc
4.MySQLSyntaxErrorException:将更改下沉到mysql中您的SQL语法中有错误;
mysql
、
apache-kafka
、
apache-kafka-connect
、
cdc
、
debezium
我使用获取数据事件,使用
kafka
-
connect
-
jdbc
接收更改。=$
KAFKA
_
CONNECT
_PLUGINS_DIR/
kafka
-
connect
-
jdbc
ARG
KAFKA
_
JDBC
_VERSION/$
KAFKA
_
JDBC
_VERSION/
kafka
-<em
浏览 5
提问于2020-06-20
得票数 0
1
回答
不支持的源数据类型:
JDBC
Postgres
Sink
连接器在使用
Kafka
主题时的结构错误
postgresql
、
jdbc
、
apache-kafka
、
avro
、
confluent-schema-registry
:608) at io.confluent.
connect
浏览 16
提问于2022-03-17
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
这可能是北半球最暖的Kafka Connect数据管道教程:2
读书笔记:《How to Build a Scalable ETL Pipeline with Kafka Connect》
这可能是北半球最暖的Kafka Connect数据管道教程:3
基于Kafka Connect的流数据同步服务实现和监控体系搭建
打造实时数据集成平台 DataPipeline基于Kafka Connect应用
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券