腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(1923)
视频
沙龙
2
回答
Kafka
Connect
Sink
"
Passthrough
“
连接器
apache-kafka
、
apache-kafka-connect
kafka
jdbc接收器
连接器
是否支持将其消耗的内容写入不同的主题。我正在寻找一个直通机制,如下图所示。也许我可以修改现有的接收器
连接器
来实现这一点?Topic 1 ->
Sink
Connector -> Topic 2 V DB
浏览 10
提问于2019-02-22
得票数 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
-
connect
-
sink</e
浏览 1
提问于2017-06-09
得票数 0
2
回答
复位卡夫卡连接水槽
连接器
apache-kafka
、
apache-kafka-connect
、
aerospike
我想重置AerospikeSink卡夫卡
连接器
偏移量,我是通过删除
连接器
消费者组(
connect
-*)偏移量,然后重新创建它。注意:创建具有新名称的新
连接器
的没有解决问题。在重置补偿之前: 重置补偿后: 在用tasks = []重新创建
连接器
之后在使用tasks在RUNNING状态下重新创建
连接器
之后:
Kafka
Connect
日志:org.apache.
kafka
.
connect
浏览 13
提问于2021-08-13
得票数 2
回答已采纳
2
回答
kafka
连接
连接器
不会自动启动
apache-kafka
、
apache-kafka-connect
我有一个
Kafka
连接源和接收器
连接器
,用于将数据放入
Kafka
中并将其取出来。我正在使用docker-compose运行
Kafka
和
Kafka
Connect
,它在分布式模式下运行
connect
。确保在
connect
启动时它能找到我的插件,但它实际上不会做任何事情,除非我对JSON执行POST操作,包括/connectors中的配置。在安装插件时,我是否遗漏了一个步骤,或者在将
连接器
分配给工作人员之前,是否需要通过REST
浏览 21
提问于2019-02-26
得票数 3
回答已采纳
2
回答
无法在
Kafka
Connect
2.4中成功覆盖我的
连接器
java
、
apache-kafka
、
apache-kafka-connect
我想创建一个这样的例子: Map<String, String>ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest"); 接下来,我将创
浏览 6
提问于2020-04-09
得票数 1
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
回答已采纳
2
回答
从
Kafka
到Vertica的数据导入(vkconfig
Kafka
连接器
)
apache-kafka
、
apache-kafka-connect
、
vertica
我知道Vertica有从
Kafka
导入数据的vkconfig。但是,Confluent似乎也有一个
连接器
可以做同样的事情。正如他们的网站所说:"Vertica
Sink
Connector for Confluent Platform -您可以使用
Kafka
Connect
Vertica
Sink
连接器
将Apache
Kafka
Vertica
Sink
连接器
定期轮询
Kafka
中的记录并将
浏览 0
提问于2020-02-13
得票数 0
2
回答
Kafka
Connect
-如何删除
连接器
apache-kafka
、
apache-kafka-connect
我创建了一个cassandra-
sink
连接器
,之后我在connector.properties文件中做了一些修改。在停止worker并再次启动它之后,现在当我使用以下命令添加
连接器
时:我得到以下错误: Error: the <em
浏览 0
提问于2018-02-23
得票数 16
回答已采纳
1
回答
如何在
kafka
接收器
连接器
中设置特定表?
apache-kafka
、
apache-kafka-connect
、
confluent-platform
我使用的是confluent
kafka
连接器
。我想将数据插入到接收器
连接器
中的特定表TB_TEST_
KAFKA
中。我已经创建了这个表。 auto.create=false。我不知道接收器
连接器
的属性、表名、键。但是错误 Caused by: org.apache.
kafka
.
connect
.errors.ConnectException: Table "TB_TEST_
KAFKA
" is missing andat io.co
浏览 51
提问于2021-08-10
得票数 0
1
回答
Docker容器中的
Kafka
连接:未添加
连接器
apache-kafka
、
apache-kafka-connect
我使用以下命令,该命令来自
Connect
教程: --name=
kafka
-
connect
-test \localhost:28083/connector-plugins { "class": "org.apache.
kafka
.
connec
浏览 0
提问于2020-03-11
得票数 0
回答已采纳
1
回答
Kafka
Connect
群集不加载简单的
连接器
插件
java
、
apache-kafka
、
apache-kafka-connect
我试图在
Connect
集群中加载一个简单的
Kafka
连接器
。我为
连接器
创建了jar,并启动了
Kafka
作为对接器。在日志中,我可以看到它正在加载插件。码头正确挂载jar文件。":"5.5.0"},{"class":"io.confluent.
connect
.elasticsearch.ElasticsearchSinkConnector","type":"
sink
&quo
浏览 4
提问于2021-10-19
得票数 1
回答已采纳
4
回答
Kafka
connect
不适用于文件流
streaming
、
apache-kafka
、
apache-kafka-connect
我一直在使用
Kafka
connect
for confluent platform,使用的指南如下 但是它不再更新接收器文件,源文件中的任何更改都不会写入
kafka
主题中。
浏览 0
提问于2016-09-07
得票数 0
1
回答
本地系统中的
kafka
进出口数据
hadoop
、
apache-kafka
、
bigdata
sink
.properties。但我错了 错误未能为配置/连接文件-
sink
.properties创建作业,(org.apache.
kafka
.
connect
.cli.ConnectStandalone:89) 2017-05-1021:26:49,110错误停止后,
连接器
错误(org.apache.
kafka
.
connect
.cli.ConnectStandalone:100) java.util.concurrent.ExecutionException:
浏览 2
提问于2017-05-11
得票数 0
1
回答
用于
Kafka
流的REST生产者
连接器
rest
、
apache-kafka
、
apache-kafka-connect
我有一个web服务器接收一些事件作为post请求,我想处理使用
Kafka
流。我可以使用哪个源
连接器
来实现这一点?
浏览 12
提问于2020-10-20
得票数 0
1
回答
kafka
接收器
连接器
中无效JSON的错误处理
mongodb
、
error-handling
、
apache-kafka
、
apache-kafka-connect
应该发生的是
连接器
应该跳过并记录无效的JSON,并保持
连接器
运行。我的分布式模式
连接器
如下所示: "name": "
sink
-mongonew_test1", "connector.class": "com.mongodb.
kafka
.
connect
.MongoSinkConnector", "key.ignore"
浏览 0
提问于2020-02-11
得票数 0
1
回答
Kafka
主题对象到spark数据帧的转换和写入HDFS
scala
、
dataframe
、
apache-spark
、
apache-kafka
、
apache-kafka-connect
我试图在火花编码中创建
kafka
消费者,而创建I am into exception.My的目的是我必须从主题中读取并需要写入到HDFS路径中。args: Array[String]): Unit = { .appName("spark Oracle
Kafka
") .getOrCreate() .read .format("<e
浏览 13
提问于2019-09-03
得票数 0
1
回答
kafka
连接elasticsearch
连接器
(接收器)数据移动(几乎)实时
elasticsearch
、
apache-kafka-connect
尽管我查看了所有文档和,但我仍然找到了如何配置
连接器
,以便将数据从
kafka
移动到elasticsearch (接近于实时)。也就是说,让
连接器
每秒使用来自(
kafka
)主题的消息,并将它们写入elasticsearch,模拟从
kafka
流到elasticsearch的消息流。这是
连接器
的当前配置: "name": "elasticsearch-
sink
", &q
浏览 1
提问于2020-02-18
得票数 0
1
回答
为什么我的卡夫卡S3
连接器
水槽删除我的主题后,创造(卡夫卡
连接器
重新启动)?
apache-kafka
、
confluent-platform
、
s3-kafka-connector
我使用Confluent的
Kafka
连接器
将数据从
Kafka
汇到一个MinIO桶中。我在Kubernetes环境中使用io.confluent.
connect
.s3.S3SinkConnector。因此,为了执行主题添加,我使用了
Kafka
: configuration = requests.get("http://
kafka
-
connect
-clus
浏览 10
提问于2021-03-19
得票数 0
回答已采纳
1
回答
如何自动运行
Kafka
连接
连接器
(例如在生产中)?
apache-kafka
、
apache-kafka-connect
、
confluent-platform
卡夫卡连接开始时(例如在汇合平台),是否有自动加载(多个)
Kafka
连接
连接器
的方法?到目前为止我发现的是:是否还有另一种方法,例如,将所有的
连接器
都包含在“
Connect
-独立的\\Distributed.properties”文件中(类似于在KSQL -server.pr
浏览 2
提问于2019-06-06
得票数 5
4
回答
卡夫卡连接找不到
连接器
apache-kafka
、
apache-kafka-connect
、
confluent-platform
我正在尝试使用
Kafka
Connect
Elasticsearch
连接器
,但没有成功。, type=
sink
, typeName='
sink
', location='classpath'}, PluginDesc{klass=class org.apache.
kafka
.
connect
.file.FileStreamSourceConnector=
sink
, typeName='
sink</e
浏览 1
提问于2018-11-21
得票数 9
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
以Kafka Connect作为实时数据集成平台的基础架构有什么优势?
这可能是北半球最暖的Kafka Connect数据管道教程:3
Kafka技术内幕之概述
这可能是北半球最暖的Kafka Connect数据管道教程:2
基于Kafka Connect的流数据同步服务实现和监控体系搭建
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券