腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(8759)
视频
沙龙
1
回答
运行
kafka
connect
worker
时
出现
如此
多
的
异常
apache-kafka
、
apache-kafka-connect
在
运行
Kafka
Connect
worker
时
遇到了许多
异常
。我已经设置了所有的
worker
属性,并且所有的jar路径看起来都很好。2020-07-23 18:41:58 WARN Reflections:104 - could not create Dir file:/
kafka
/clients/build/libs/
kafka</
浏览 64
提问于2020-07-24
得票数 0
1
回答
Kafka
连接,插件路径
docker
、
apache-kafka
、
apache-kafka-connect
/home/madmin/connectorf - PLUGIN_PATH在我
的
PC上使用jar - connector
CONNECT
_PLUGIN_PATH -默认变量by confluent谢谢回答
CONNECT
_PLUGIN_PATH: "/usr/share/java,/usr/share/confluent-hub-components" volumes: -/home/madmin
浏览 2
提问于2021-03-30
得票数 0
2
回答
使用环境变量在停靠程序中
运行
Shell脚本
docker
、
apache-kafka
、
apache-kafka-connect
、
docker-entrypoint
我正在
运行
一个docker文件,作为切入点执行debezium服务。,但是当我将文件名作为环境变量传递
时
,它失败了。命令在停靠文件中 入口点${
connect
_standalone},${
connect
_standa
浏览 6
提问于2022-06-14
得票数 0
1
回答
卡夫卡连接:“任务在这个工人中已经存在”
apache-kafka
、
apache-kafka-connect
我看到我
的
连接器
的
状态,我有这个
异常
。org.apache.
kafka
.
connect
.errors.ConnectException: Task already exists in this
worker
: *name of the connector*
浏览 0
提问于2018-09-03
得票数 5
3
回答
Kafka
Connect
堆空间不足
java
、
apache-kafka
、
jvm
、
apache-kafka-connect
启动
Kafka
连接(
connect
-standalone)后,我
的
任务在启动后立即失败: at java.nio.HeapByteBuffer:222) atorg.apache.
kafka
.
conn
浏览 263
提问于2017-02-01
得票数 30
回答已采纳
2
回答
将来自
kafka
的
消息存储到hdfs
python
、
apache-kafka
、
hdfs
、
apache-kafka-connect
、
confluent-platform
我使用
的
是confluent-
Kafka
和python。我想将
Kafka
连接到Hdfs,并将一些特定
的
数据直接存储在Hdfs中。我找到了confluent HDFS连接器,但我不知道如何将它与我
的
python脚本连接起来。有什么想法吗?或者有什么替代方法可以将消息直接从
Kafka
存储到Hdfs?
浏览 1
提问于2020-06-08
得票数 0
1
回答
Kafka
Connect
JDBC接收器连接器问题
apache-kafka
、
apache-kafka-connect
、
confluent-platform
运行
JDBC接收器连接器
时
出现
以下错误 [2020-01-08 15:05:39,271] ERROR Plugin class loader for connector: 'io.confluent.
connect
.jdbc.JdbcSinkConnectorReturning: org.apache.
kafka
.
connect
.runtime.isolation.DelegatingClassLoader@6f2cfcc2 (org.apache.
kafka</em
浏览 15
提问于2020-01-09
得票数 0
2
回答
使用AWS胶水
的
Kafka
amazon-web-services
、
apache-kafka
、
aws-glue
我们有一个
运行
在AWS上
的
Kafka
服务,并计划使用Athena/S3对我们
的
分析数据进行长期存储。是否可以将
Kafka
与AWS Glue服务一起使用,以便从
Kafka
中读取并存储在s3中?
浏览 1
提问于2018-03-12
得票数 1
2
回答
找不到任何实现连接器且名称与com.mongodb.
kafka
.
connect
.MongoSinkConnector匹配
的
类
apache-kafka
、
apache-kafka-connect
": "com.mongodb.
kafka
.
connect
.MongoSinkConnector", "version": "1.5.0"{"class": "com.mongodb.
kafka
.
connect
.MongoSourceConnector", "type": "sour
浏览 3
提问于2021-04-23
得票数 1
1
回答
Kafka
Elasticsearch接收器连接器:连接错误
elasticsearch
、
apache-kafka
、
apache-kafka-connect
我刚开始使用
Kafka
和
Kafka
连接器。我一直在尝试使用Elastic Search作为接收器,使用
Kafka
连接器从我
的
应用程序中流式传输数据。我可以看到
Kafka
中
的
消息,但我
的
连接器一直抛出下面的错误: ERROR WorkerSinkTask{id=elasticsearch-sink-0} Task threw an uncaughtand unrecoverable exception (org.apache.
kafka
.
浏览 2
提问于2020-09-22
得票数 0
回答已采纳
1
回答
在码头上添加MongoDB Sink连接器?
mongodb
、
docker
、
apache-kafka
、
apache-kafka-connect
、
confluent-platform
我有一台Ubuntu机器,在这里我遵循以下步骤来
运行
与docker汇合
的
平台。 我用正确
的
mongo端点编辑了etc/MongoDbSinkConnector.properties文件我创建了一个具有以下内容
的
文件Dockerfile
运行
合流-集线器安装-不提示/tmp/hpgrahsl-
kafka
-
connect
-mongodb
浏览 5
提问于2021-09-06
得票数 0
回答已采纳
1
回答
合流InfluxDB接收器连接器
apache-kafka-connect
、
confluent-platform
我正在尝试使用Confluent InfluxDB sink connector将主题中
的
数据放入我
的
InfluxDB中。
Connect
UI创建新
的
连接器
时
,我得到
的
是以下
异常
: org.apache.
kafka
.
connect
.errors.ConnectException: Exiting WorkerSinkTask这里有没有我遗漏
的
配置?更新:这是我
的
worker
配置:
浏览 22
提问于2019-03-18
得票数 0
3
回答
如何在
worker
创建
时
创建
Kafka
Connect
连接器?
docker
、
apache-kafka
、
apache-kafka-connect
假设我有一个
Kafka
Connect
worker
,它是我使用confluentinc/cp-
kafka
-
connect
镜像中
的
Docker构建
的
,部署到服务器上并启动一个
worker
。但是如何在
worker
启动
时
通过脚本创建连接器(如果还不存在的话)呢?我可以给我
的
工人在它旋转后
运行
的
步骤吗?
浏览 1
提问于2020-03-21
得票数 0
2
回答
Kafka
MirrorMaker2主题-复制因子
apache-kafka
、
apache-kafka-mirrormaker
它们作为单独
的
实例
运行
。因此,我
的
本地有两个集群,每个集群上有一个代理。经纪人们运转良好。现在,当我尝试在本地
运行
镜像生成器
时
,会遇到以下问题。[2020-02-14 16:58:18,371] ERROR [
Worker
clientId=
connect
-2, groupId=dest-mm2] Uncaught exception in herder(KafkaOffsetBackingStore.java:109) at org.apache.
ka
浏览 7
提问于2020-02-15
得票数 3
2
回答
java.lang.NoClassDefFoundError: io/confluent/
connect
/avro/AvroConverterConfig
avro
、
apache-kafka-connect
、
confluent-schema-registry
kafka
2.12-2.4.0融合5.4.1但是当我发布conector请求
时
。": "k1:9092,k2:9092,k3:9092"} 抛出
异常
。[2020-04-23 10:37:00,064] INFO Creating task dbz-mysql-avro-co
浏览 0
提问于2020-04-23
得票数 0
3
回答
使用Confluent Cloud和Snowflake
Kafka
连接器
时
出现
SF_
KAFKA
_CONNECTOR名称为空或无效错误
apache-kafka
、
apache-kafka-connect
、
snowflake-cloud-data-platform
我有一个在Confluent Cloud中
运行
的
集群,并且能够使用其他应用程序生成和使用数据。然而,当我尝试连接Snowflake
Kafka
连接器
时
,我收到以下错误: [2019-10-15 22:12:08,979] INFO Creating connector source-snowflakeof type com.snowflake.
kafka
.connector.SnowflakeSinkConnector (org.apache.
kafka
.
connect
浏览 0
提问于2019-10-16
得票数 2
1
回答
构建弹性PreBuiltTransportClient
时
的
NoSuchMethodError
java
、
elasticsearch
、
apache-kafka
、
elasticsearch-5
、
apache-kafka-connect
由于调试需要连接我
的
dockerized Elastic实例
的
Kafka
连接器相当困难,我不明白为什么我会得到这个
异常
……Settings settings = Settings.builder:30) at org.apache.<
浏览 0
提问于2017-09-12
得票数 1
1
回答
Kafka
连接任务随机死于NPE
java
、
apache-kafka
、
apache-kafka-connect
我开始
运行
一个自定义
的
kafka
连接插件,将
kafka
中
的
数据转储到ElasticSearch中,然后我
的
任务就会周期性地无缘无故地死亡(几个小时到一天后)curl -<init>(TaskConfig.java:52)\n\tat org.apache.
kafka
.
connect
.runtime.
Worker
.startTask(
Worker
.java:313)\n&l
浏览 4
提问于2017-07-31
得票数 4
回答已采纳
2
回答
如何设置
kafka
-
connect
连接器和任务
的
JVM堆大小?
apache-kafka
、
apache-kafka-connect
kafka
connect
是否在
kafka
connect
流程中启动新
的
连接器及其任务?否则将派生一个新
的
JVM进程。如果它在
kafka
连接过程中启动插件,那么我需要通过
KAFKA
_
CONNECT
_JVM_HEAP_OPT设置
kafka
connect
JVM堆
的
大小(使用confluent docker镜像)。然后,问题是,如果我启动了许多任务或连接器,它们将共享JVM堆,因此很
浏览 4
提问于2018-05-31
得票数 4
1
回答
无法以独立模式连接并描述
Kafka
集群
apache-kafka
、
apache-kafka-connect
我已经安装了zookeeper和
kafka
,zookeeper
运行
得很好,但根据我
的
要求,我想
运行
Kafka
-
connect
独立连接
kafka
和cassandsra。我正在使用以下命令启动
kafka
服务器
kafka
/bin/
connect
-standalone.sh
kafka
/config/
connect
-standalone.proper
浏览 297
提问于2021-08-10
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
基于Kafka Connect的流数据同步服务实现和监控体系搭建
深入理解Kafka Connect:转换器和序列化
Kafka 安装及快速入门
基于Kafka Connect的应用实践——打造实时数据集成平台
打造实时数据集成平台 DataPipeline基于Kafka Connect应用
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券