腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
Kafka
Connect
JDBC
在
JsonConverter
上
失败
apache-kafka
、
apache-kafka-connect
我正在设计一个MySQL -> Debezium ->
Kafka
-> Flink ->
Kafka
->
Kafka
Connect
JDBC
-> MySQL。下面是我
在
Flink
上
写的示例消息(我也尝试过使用
Kafka
控制台生产者) { "type": "struct", "fields"
浏览 70
提问于2019-02-27
得票数 0
回答已采纳
1
回答
Kafka
JDBC
Sink连接器为具有可选字段的模式的消息提供了一个空指针异常
json
、
jdbc
、
apache-kafka
、
apache-kafka-connect
、
confluent-platform
Kafka
连接器为消息提供了一个Null指针异常,其中模式
在
“parentId”中有一个可选字段。我错过了什么吗?我正在使用开箱即用的
JSONConverter
和
JDBC
Sink连接器。=record_value但是
JDBC
Sink连接器
在
可选字段parentId中
失败
,如 org.apache.
kafka
.
connect
.errors.ConnectException(
Json
浏览 0
提问于2019-01-11
得票数 2
回答已采纳
1
回答
连接器配置不包含连接器类型。
apache-kafka
、
apache-kafka-connect
、
confluent-platform
我试图使用连接到集群
上
的PostgreSQL数据库(该数据库不是由集群直接管理的)。我用以下命令调用了
Kafka
Connect
:这是worker.properties=org.apache.
kafka
.
connect
.json.
JsonConverter
internal.value.converter=org.apa
浏览 0
提问于2018-04-16
得票数 3
回答已采纳
1
回答
数据管道'MSSQL ->
Kafka
-> CH‘不工作
sql-server
、
jdbc
、
apache-kafka
、
clickhouse
我
在
Kafka
中创建了到SQL Server的
JDBC
连接,数据已成功加载到主题中。/bin/
kafka
-console-consumer --bootstrap-server localhost:9092 --topic my-testsql-topic --from-beginning我用引擎
Kafka
(关于这个主题)和物化视图创建了一个新表,但没有成功。
kafka
_broker_list = localhost:9092,
kafka
浏览 105
提问于2020-05-21
得票数 1
3
回答
不工作json模式的
Kafka
jdbc
接收器连接器
json
、
jdbc
、
apache-kafka
、
apache-kafka-connect
使用最新的
kafka
和汇流
jdbc
接收器连接器。msgschema" "payload": { "msg": "hi"}org.apache.
kafka
.
connect
.errors.DataException:
JsonConverter
with schemas.enable requires "s
浏览 1
提问于2018-02-28
得票数 2
回答已采纳
2
回答
在
Kafka
Connect
中找不到
jdbc
的合适驱动程序:mysql
jdbc
、
apache-kafka
、
apache-kafka-connect
、
confluent-platform
=10.33.62.20:9092,10.33.62.110:9092,10.33.62.200:9092key.converter.schemas.enable=true value.converter.schemas.enablekey.convert
浏览 1
提问于2018-08-09
得票数 3
1
回答
查询模式下
kafka
jdbc
源连接器错误
postgresql
、
jdbc
、
apache-kafka
我
在
kafka
中有一个JDBCSourceConnector,它使用查询从数据库中流数据。但是,对于我为选择数据而编写的查询,我有问题。误差
在
“用户”TimestampIncrementingTableQuerier{name='null',= "SchoolUserPivots:221) org.postgresql.util.PSQLE
浏览 1
提问于2019-06-27
得票数 0
1
回答
kafka
connect
如何从有效负载中筛选模式元数据
apache-kafka
、
apache-kafka-connect
io.confluent.
connect
.
jdbc
.JdbcSourceConnector下面是我的worker.properties key.converter=org.apache.
kafka
.
connect
.json.
JsonConverter
value.
浏览 2
提问于2019-04-10
得票数 1
回答已采纳
1
回答
卡夫卡连接不输出JSON
apache-kafka
、
apache-kafka-connect
我知道它是这样做的,因为当我
在
python中使用来自该主题的消息时,我会在每个消息的顶部看到模式。我这样运行连接器: /usr/bin/
connect
-standalone /etc/schema-registry/
connect
-json-standalone.properties /etc/
kafka
-
connect
-
jdbc
=org.apache.
kafka
.
connect</
浏览 3
提问于2016-09-08
得票数 0
1
回答
MySQL接收器连接器-
JsonConverter
- DataException:未知架构类型:空
mysql
、
jdbc
、
apache-kafka
、
apache-kafka-connect
connection.password":"password", "auto.evolve":"true", "value.converter.schemas.enable":"tru
浏览 16
提问于2021-07-28
得票数 0
1
回答
添加
kafka
connect
jdbc
驱动程序
jdbc
、
apache-kafka
、
sap
、
apache-kafka-connect
、
confluent-platform
我正在尝试通过使用
JDBC
的
kafka
connect
访问SAP Advantage DB。我使用的是docker容器,并且添加了
jdbc
driver Jar,地址是:connector.class=io.confluent.
connect
.
jdbc
.JdbcSourceConnectorconnection.password=passwordconnection.user=admin name=JdbcSour
浏览 1
提问于2018-06-28
得票数 0
1
回答
SQLException找不到适合
jdbc
服务器的驱动程序
apache-kafka
、
apache-kafka-connect
、
confluent-platform
:107)bootstrap.servers=localhost:9092internal.key.converter=org.apache.
kafka
.
connect
.json.
JsonConverter
internal.value.convertershare/java
浏览 0
提问于2018-04-20
得票数 2
1
回答
如何通过
Kafka
JDBC
连接器
在
消息中设置主键
apache-kafka
、
apache-kafka-connect
标题怎么说,有一种方法可以设置
Kafka
JDBC
Source连接器从数据库读取的记录的主键吗?这是来自
connect
-file-source.properties的配置 name=
jdbc
_source_postgres_foobar_01 connector.class=io.confluent.
connect
.
jdbc
.JdbcSourceConnectorkey.converter=org.apache.
kafka
.
connect
.json.
浏览 22
提问于2020-10-16
得票数 0
2
回答
卡夫卡连接不加载手动构建的连接器
apache-kafka
、
apache-kafka-connect
、
aiven
但是,当我运行连接时,它会抛出错误,说“找不到实现连接器的类,哪个名称与io.aiven.
connect
.
jdbc
.JdbcSourceConnector匹配”bootstrap.servers=*******:9092 key.converter=org.apache.
kafka
.
connect
.json.
JsonConverter
value.converter=org.apache.
kafka<
浏览 6
提问于2021-08-18
得票数 0
1
回答
kafka
jdbc
接收器连接器抛出org.apache.
kafka
.
connect
.errors.DataException (结构模式的字段名未正确指定)插入PG表
json
、
jdbc
、
apache-kafka
、
apache-kafka-connect
、
confluent-platform
我
在
我的项目中使用了
kafka
-
jdbc
-接收器-连接器,其中我需要在
kafka
主题(
kafka
_subs)
上
发布一些JSON,然后通过使用
JDBC
-接收器-连接器,我需要在模式下的postgres表",
浏览 1
提问于2021-09-09
得票数 0
1
回答
使用JdbcConnectionSource连接器的
Kafka
无法创建任务(连接器正在运行,但任务没有)
apache-kafka
、
apache-kafka-connect
我似乎经常基于查询从JdbcConnectionSource创建一个
Kafka
连接器,并且
在
状态“运行”的情况下成功地创建了连接器,但没有创建任务。
在
我的容器的控制台日志中,我没有看到任何错误的迹象:没有错误,没有警告,也没有解释为什么任务
失败
。我可以让其他连接器工作,但有时没有。" ENV
CONNECT
_KEY_CONVERTER="org.apache.
kafka
.
connect
.json.
JsonConverter
&qu
浏览 1
提问于2020-04-22
得票数 5
1
回答
使用
Kafka
connect
:JdbcSourceConnector获取JSON中的编码值
json
、
oracle
、
jdbc
、
apache-kafka
、
apache-kafka-connect
我
在
独立配置中使用
Kafka
从Oracle读取数据。bootstrap.servers=********:9092 key.converter=org.apache.
kafka
.
connect
.json.
JsonConverter
value.converter=org.apache.
kafka<
浏览 1
提问于2021-08-11
得票数 0
回答已采纳
2
回答
无法使用
Kafka
将数据从MySQL流到Postgres
postgresql
、
jdbc
、
apache-kafka
我第一次尝试了
Kafka
,并使用AWS建立了
Kafka
集群。目标是将数据从MySQL服务器流到Postgresql。我使用debezium MySQL连接器作为源,使用汇流
JDBC
连接器作为接收器。transforms.unwrap.add.source.fields": "ts_ms", "internal.key.converter": "org.a
浏览 11
提问于2020-07-16
得票数 3
1
回答
kafka
连接
JDBC
接收器。展平JSON记录时出错
jdbc
、
apache-kafka
、
apache-kafka-connect
、
confluent-platform
我使用
Kafka
connect
JDBC
Sink Connector将主题中的数据存储到SQL Server表中。数据需要扁平化。=1value.converter.schemas.enable=truetransforms.flatte
浏览 31
提问于2019-09-10
得票数 2
回答已采纳
2
回答
在
与
Kafka
Connect
连接时,没有为
jdbc
找到合适的驱动程序
oracle
、
jdbc
、
apache-kafka
、
apache-kafka-connect
、
ojdbc
我试图
在
Kafka
中运行一个oracle源连接器,
在
独立模式下使用Oracle
jdbc
8 (ojdbc8.jar)。value.converter=org.apache.
kafka
.
connect
.json.
JsonConverter
value.converter.schemas.enable
connect
-standalone.properties文件如下所示: key.con
浏览 2
提问于2020-03-11
得票数 3
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
基于Kafka Connect的流数据同步服务实现和监控体系搭建
深入理解Kafka Connect:转换器和序列化
这可能是北半球最暖的Kafka Connect数据管道教程:3
kafka connect 应用之:sqlite到hive的etl配置过程
读书笔记:《How to Build a Scalable ETL Pipeline with Kafka Connect》
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券