腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(2569)
视频
沙龙
1
回答
使用
kafka-
Connect
-
spooldir
连接器
在
Kafka
connect
中
解析
dd.MM.yyyy
格式
的
日期
apache-kafka
、
apache-kafka-connect
我正在尝试
使用
https://github.com/jcustenborder/
kafka
-
connect
-
spooldir
中
的
SpoolDirCsvSourceConnector 我
在
Kafka
中有以下
连接器
配置: connector.class=com.github.jcustenborder.
kafka
.
connect
.
spooldir
浏览 13
提问于2019-02-09
得票数 1
回答已采纳
2
回答
为什么我
的
使用
者控制台不与我
的
文本文件同步?
apache-kafka
我按照建议设置了所有的东西,以便快速启动,我
使用
一个文本文件作为源代码或生产者,其中包含一个句子。当我第一次启动消费控制台时,我能够
在
文件
中
读取句子(JSON
格式
),但是当我
在
文件
中
添加一些东西时,它并没有显示
在
消费控制台中,当我
使用
生产者控制台
在
主题中添加某些内容时,它在消费控制台中显示出了正确
的
方式
浏览 4
提问于2020-03-17
得票数 0
回答已采纳
1
回答
卡夫卡
连接器
从csv读取并转换为avro
apache-kafka
、
avro
、
apache-kafka-connect
是否有卡夫卡
连接器
从csv
中
读取并转换为Avro,然后再将其推上主题? 我已经通过了熟悉
的
,但它只是阅读和推动
的
主题。我计划修改代码库以供我
的
自定义
使用
,但在进行更改之前,我只想检查是否已经有这样
的
连接器
可用。
浏览 2
提问于2019-02-06
得票数 0
1
回答
如何将mqtt
的
负载数据转换为
kafka
字符串类型
apache-kafka
、
mqtt
、
apache-kafka-connect
现在我正在尝试从mqtt消息连接到
kafka
(实际上是
kafka
中
的
spark streaming )和Spark-2.1.0,
Kafka
- 0.10.1.1 client = new MqttClient(brokerUrl, MqttClient.generateClientId, persistence) client.
connect
MqttExcept
浏览 18
提问于2017-02-11
得票数 0
回答已采纳
1
回答
我们可以
在
Windows操作系统
中
运行Confluent JDBC
Kafka
连接器
吗?
jdbc
、
apache-kafka
、
apache-kafka-connect
、
confluent-platform
我们计划在Windows操作系统
中
安装和运行Confluent
的
JDBC
连接器
(没有安装Docker和Cygwin并安装curl )。
在
Windows操作系统
中
运行Confluent
的
JDBC
连接器
的
最佳方式是什么?
浏览 25
提问于2019-01-17
得票数 0
回答已采纳
1
回答
如何读取文件夹
中
的
文本文件并在windows上写入
Kafka
主题
python
、
apache-kafka
我有一个本地设置卡夫卡在我
的
windows 10机器。目前,我仍然在学习卡夫卡,并在我
的
本地机器上测试它
的
能力。.\bin\windows\
kafka
-console-consumer.bat --bootstrap-server localhost:9092 --topic test 现在,我试图将在网络文件夹中生成
的
文本文件
的
内容流到
Kafka
主题。我读
浏览 5
提问于2021-05-05
得票数 0
回答已采纳
1
回答
设置
kafka
-
connect
以从远程代理获取数据
apache-kafka
、
remote-server
、
apache-kafka-connect
我正在尝试设置
Kafka
连接接收器
连接器
。
Kafka
connect
是
Kafka
connect
worker (confluent-3.2.0)
的
一部分。我
在
机器A上启动并运行了一个
Kafka
代理(confluent-3.2.0)。我想在另一台机器B上设置
Kafka
-
connect
-sink
连接器
,以
使用
自定义
的
Kafka
-<
浏览 1
提问于2017-06-09
得票数 0
1
回答
如何通过java代码
使用
Kafka
连接器
?
apache-kafka
、
apache-kafka-connect
目前我
在
独立模式下
使用
Kafka
SpoolDir
连接器
。将所需
的
配置添加到属性文件后,我
使用
以下命令启动
连接器
kafka
/bin/
connect
-standalone.sh
connect
-standalone.properties file-source.properties有没有办法只
使用
java代码启动
连接器
(stadalone
浏览 16
提问于2020-09-09
得票数 0
回答已采纳
1
回答
如何在卡夫卡连接
连接器
com.github.jcustenborder.
kafka
.
connect
.
spooldir
.SpoolDirCsvSourceConnector?
中
更新Ack参数
apache-kafka
、
apache-kafka-connect
、
kafka-producer-api
我尝试
使用
这个
Kafka
连接器
: com.github.jcustenborder.
kafka
.
connect
.
spooldir
.SpoolDirCsvSourceConnector
在
Kafka
集群上公开我没有看到任何关于Acks
的
参数[2022-02-03 16:03:46,551] INFO ProducerConfig val
浏览 8
提问于2022-02-03
得票数 0
2
回答
用于"Ctrl+A“分隔文件
的
kafka
连接器
apache-kafka
、
apache-kafka-connect
、
confluent-platform
我学会了
使用
Kafka
connect
通过Confluent
SpoolDir
连接器
来
使用
CSV文件。对于"Ctrl+A“分隔
的
文件,有没有办法
使用
这个
连接器
(或者是否存在其他这样
的
连接器
)?我要
使用
的
(源)文件
中
的
记录用换行符分隔,而列用"Ctrl+A“分隔。
浏览 9
提问于2020-09-04
得票数 1
回答已采纳
4
回答
Kafka
-
Connect
将SQL JAR文件添加到类路径
java
、
apache-kafka
、
apache-kafka-connect
我正在尝试部署一个独立
的
连接作业来从mssql服务器流传输,但是我遇到了一个问题(
Kafka
-
Connect
是我
的
Ambari部署
的
一部分,而不是docker)。这是我正在
使用
的
属性文件:connector.class=io.confluent.
connect
.jdbc.JdbcSourceConnector/servernamequery=SELEC
浏览 1
提问于2018-05-29
得票数 1
1
回答
kafka
连接器
启动期间
的
秘密管理
apache-kafka-connect
我
使用
Kafka
连接器
作为源
连接器
。该文档提供了一种
使用
REST API管理
的
方法。 如果
kafka
-connector已经启动并运行,并且我们尝试创建一个新
的
连接器
(实例),那么这是可行
的
。但是
在
Kafka
Connect
worker本身启动期间,如果我们需要在分布式属性文件
中
传递一些凭据,比如SSL证书密码。是否可以
使用
<
浏览 0
提问于2020-06-16
得票数 0
2
回答
卡夫卡
连接器
如何将数据从卡夫卡流到MongoDB
mongodb
、
apache-kafka
、
apache-kafka-connect
我想通过
使用
Kafka
连接器
将数据从
Kafka
流到MongoDB。我找到了这个。但没有什么可做
的
。提前谢谢你。我试过
的
Step1:我从下载mongo-
kafka
-
connect
-0.1-all.jar
浏览 2
提问于2019-07-04
得票数 7
回答已采纳
2
回答
我能把卡夫卡连接服务作为独立
的
服务吗?
apache-kafka
、
apache-kafka-connect
我
在
第一服务器
使用
apache
kafka
,
在
第二服务器
使用
apache动物园管理员。我希望在其他server.Is中有卡夫卡连接服务,可以
使用
独立
的
服务。我需要阿帕奇卡夫卡连接或融合卡夫卡连接。
浏览 7
提问于2022-06-29
得票数 0
2
回答
当您
使用
kafka
(
在
坞容器
中
)时,插件路径到底在哪里?
apache-kafka
、
docker-compose
、
apache-kafka-connect
--我用卡夫卡,卡夫卡-连接(图片:confluentinc/cp
connect
)所以..。我
的
问题是
在</
浏览 26
提问于2022-05-20
得票数 0
1
回答
将
Kafka
工作进程作为服务运行
apache-kafka
、
apache-kafka-connect
、
debezium
我让
Kafka
使用
Sql
连接器
运行。目前,这是
在
Linux服务器上运行
的
,我正在
使用
Putty连接来配置和运行所有内容。我可以
在
独立模式下启动工作进程,一切都按预期进行。然而,觉得好像应该能够离开我
的
终端会话,让工人像服务一样运行。目前,我结束了我
的
终端会话,只是重新连接到putty,但同样,这并不是感觉是正确
的
方法。有人知道如何让员工像服务一样运行吗? ./
connect
-standal
浏览 3
提问于2021-05-24
得票数 0
回答已采纳
1
回答
Elasticsearch接收器只获取新消息,而不是
使用
kafka
-
connect
-elasticsearch +时间戳SMT获取上一条消息。
elasticsearch
、
apache-kafka
、
apache-kafka-connect
我正在
使用
kafka
-
connect
Elasticsearch插件从我
的
kafka
获得消息到Elasticsearch。我
在
kafka
中
的
数据包含一个
日期
字段(时间戳
格式
)。我
的
第一个问题是当我
使用
这个插件时,Elasticsearch索引没有将
日期
字段识别为
日期
类型,而是识别为一个长
的
.我
在</e
浏览 0
提问于2018-12-25
得票数 3
回答已采纳
1
回答
如何自动运行
Kafka
连接
连接器
(例如在生产中)?
apache-kafka
、
apache-kafka-connect
、
confluent-platform
卡夫卡连接开始时(例如在汇合平台),是否有自动加载(多个)
Kafka
连接
连接器
的
方法?到目前为止我发现
的
是:是否还有另一种方法,例如,将所有的
连接器
都包含在“
Connect
-独立
的
\\Distributed.properties”文件
中</e
浏览 2
提问于2019-06-06
得票数 5
2
回答
pubSubSource:重复
使用
相同
的
消息两次
apache-kafka
、
apache-kafka-connect
、
google-cloud-pubsub
、
confluent-platform
描述部署
Kafka
和
Kafka
连接内容类型: application/json“-d”{“名称”:"pubSub
浏览 1
提问于2021-02-24
得票数 1
回答已采纳
1
回答
过滤数据库
中
的
行
mysql
、
apache-kafka
、
apache-kafka-streams
我想知道
kafka
平台是否适合下面的工作。例如,如果基于
日期
,将来可能会满足条件,那么是否有机会再次过滤被拒绝
的
邮件,以最终通过过滤器并进一步处理?在给
Kafka
提供数据之前先过滤数据行是不是更好? 谢谢。
浏览 9
提问于2017-08-11
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
深入理解Kafka Connect:转换器和序列化
Kafka 安装及快速入门
这可能是北半球最暖的Kafka Connect数据管道教程:3
以Kafka Connect作为实时数据集成平台的基础架构有什么优势?
CDC Debezium 介绍
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券