腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
2
回答
Kafka
Connect -
如何
删除
连接器
、
我创建了一个cassandra-sink
连接器
,之后我在connector.properties文件中做了一些
修改
。在停止worker并再次启动它之后,现在当我使用以下命令添加
连接器
时:我得到以下错误: Error: the
Kafka
Connect API ret
浏览 0
提问于2018-02-23
得票数 16
回答已采纳
2
回答
ClassNotFoundException与卡夫卡连接MQTT
连接器
、
、
、
我正在尝试订阅一个带有
kafka
的mqtt主题,为此我使用了以下
连接器
:。我按照上面描述的步骤做了一些
修改
,一切似乎都很顺利。但是,当我启动
连接器
时,我会得到一个 (屏幕截图),
连接器
就会停止。它似乎来自IMqttMessageListener,但我不知道
如何
解决这个问题。connector.class : be.jovacon.
kafka
.connect.MQTTSourceConnector mqtt.broker :
浏览 0
提问于2020-05-10
得票数 2
回答已采纳
1
回答
Kafka
Connect -
如何
限制创建、更新、删除特定
连接器
的权限
、
、
我面临的情况是,多个开发人员正在致力于特定的
kafka
源或接收器
连接器
配置。
连接器
通过创建、更新、删除等。必须保证 开发人员从不删除或
修改
他人的
连接器
。开发人员只能管理特定connector.class的
连接器
,例如connector.class。是否有任何方法来配置
Kafka
,将
Kafka
-Connect REST的使用限制在与
连接器
配置细节相关的特定操作上?卡夫卡ACL似乎没有涵盖这一用途。
浏览 10
提问于2022-07-22
得票数 0
回答已采纳
1
回答
Kafka
连接器
-
Kafka
主题的JMSSourceConnector
、
、
、
Confluent默认为
Kafka
主题提供此JMSSourceConnector。我在Confluent页面上没有看到任何关于这方面的文档。
浏览 13
提问于2016-09-24
得票数 1
回答已采纳
2
回答
如何
在
kafka
-conect分发模式中手动定义主题分区和复制
、
、
我使用sql-server
kafka
-connect和debezium来监视sql server数据库,但是当我发布并运行我的工作程序时,主题已经用名称{server_name}.
如何
手动更改表主题的分区和复制,或者在worker/connector配置中预先指定?此外,不同的主题可能有不同的分区和复制。
浏览 0
提问于2019-12-30
得票数 2
1
回答
Confluent 5.0.0
kafka
连接hdfs接收器:无法描述升级后的
kafka
连接消费组滞后
、
我们从Confluent 4.0.0升级到5.0.0,升级后我们无法列出
kafka
connect hdfs接收器
连接器
消费者lag。$ /opt/
kafka
/bin/
kafka
-consumer-groups.sh --bootstrap-server <hostname>:9092 --list | grep scribe_log_backend5.0.0中的消费者组命令有什么
修改
吗?
如何
跟踪我们需要根据此延迟发出警报的延迟?我们的
浏览 0
提问于2018-09-17
得票数 0
1
回答
能不能把拉比姆克和卡夫卡结合起来?
、
我正在尝试做一个POC,我们需要连接RabbitMQ和
Kafka
。我的问题是,是否有可能将RabbitMQ和卡夫卡联系起来?提前感谢
浏览 0
提问于2018-06-05
得票数 2
2
回答
如何
在消费者MQ Topic中消费
Kafka
Topic
、
、
我有一个需求,我需要消费
Kafka
Topic并将其写入MQ Topic。有人能建议我做它的最好的方法,我是新手卡夫卡。我在confluent中读过关于IBM MQ Connector的文章,但不知道
如何
实现它。
浏览 55
提问于2019-05-28
得票数 0
回答已采纳
2
回答
使用
Kafka
Connect构建数据转换服务
、
相反,
Kafka
提供了它的API接口,它对于处理配置以及任务、工作人员等都非常有用。 解决
如何
构建一个像
Kafka
这样的REST接口API,它封装了
Kafka
应用程
浏览 11
提问于2021-04-26
得票数 0
2
回答
如何
在Snowflake connector for
KAFKA
中使用连续流数据
在snowflake
连接器
中应该为主题提供什么? 因为我能够使用所需的主题名称通过单个表数据填充数据。但我有捕获连续数据流到表中的要求。
浏览 0
提问于2021-10-07
得票数 5
1
回答
有没有办法调整卡夫卡连接中的消费者配置?
、
、
我正在
修改
memsql
Kafka
连接器
代码,而且
Kafka
Connector似乎没有使用
Kafka
使用者订阅API,所以我想知道是否有任何方法来改变消费者的配置,如组id、分区分配策略,……?
浏览 10
提问于2021-01-11
得票数 1
回答已采纳
1
回答
如何
使用
kafka
轮询远程目录中的新文件
、
、
、
在这个解决方案中,我可以运行多个生产者,这将只在
kafka
队列上轮询。
浏览 0
提问于2017-09-15
得票数 0
1
回答
卡夫卡到BigQuery,使用信息的最佳方式
、
、
、
我在AWS的
Kafka
服务器会生成AVRO消息,根据我所看到的,Dataflow需要接收JSON格式的消息。因此,我搜索并找到了一篇文章,解释了
如何
向PubSub接收消息,但在PubSub上,我只看到在这种体系结构中,他们在GCP上创建了一个
Kafka
来生成消息。我需要知道的是: 可以从外部的
Kafka
服务器在PubSub上接收AVRO消息,然后使用messages反序列化消息,将其发送到Dataflow,并最终将其发送到BigQuery表?还是我需要创建一个
Kafka
并使用它来使用来自外部服务器的消
浏览 1
提问于2021-04-27
得票数 3
回答已采纳
1
回答
需要关于
如何
使用卡桑德拉卡夫卡
连接器
的帮助
、
、
我需要关于这个github代码的帮助:我能够正常地编译它,但是没有多少关于
如何
使用它的信息。我现在唯一关心的是知道我必须使用JSON格式发送到这个
连接器
的消息格式是什么,这样他就可以解释它并添加到Cassandra数据库中。First record
kafka
coordinates:({}-{}-{}). Writing them to Cassandra...最后是配置文件(cassandra-sink.propert
浏览 1
提问于2019-10-15
得票数 0
1
回答
如何
在Mule和
kafka
连接器
消费者和生产者属性文件中设置加密密码
、
我有Mule应用程序,并使用Apache
Kafka
连接器
连接主题。mule-kakfa
连接器
jar是"mule-module-
kafka
-2.1.0.jar“
连接器
使用producer.properties和consumer.properties文件,这些文件包含纯文本形式的你能建议
如何
加密这些密码和使用在mule流程中。Mule
Kafka
连接器
代码在mule流中。producerPropertiesFile="producer
浏览 42
提问于2019-06-11
得票数 0
1
回答
如何
修改
kafka
连接器
?
、
、
我已经在docker上使用终端上的curl创建了一个debezium
连接器
,并且我一直在
修改
现有的
连接器
。#"transforms.dropPrefix.regex":"procura.dbo.(.*)", "transforms.dropPre
浏览 26
提问于2020-01-21
得票数 0
回答已采纳
2
回答
Kafka
Connect HDFS Sink for JSON格式使用JsonConverter
、
、
在JSON中从
Kafka
生产/消费。使用以下属性保存到JSON中的HDFS:value.converter=org.apache.
kafka
.connect.json.JsonConverterkey.converter.schemas.enable=false制片人: curl -X POST -H "Content-Type:
浏览 0
提问于2016-11-21
得票数 1
2
回答
将
Kafka
Connect JDBC源
连接器
输出转换为自定义格式
、
、
我已经实现了一个
Kafka
Connect JDBC Source
连接器
,它连接到Oracle-Database,并将数据写入
Kafka
-Topic。目前,我已经在设置value.converter.schemas.enable=false的情况下设置了选项value.converter=org.apache.
kafka
.connect.json.JsonConverter该选项允许将JSON数据写入
Kafka
主题(顺便说一句,它工作得很好),但不包括在将数据发送到
Kafka
代理之前<e
浏览 3
提问于2021-02-18
得票数 0
1
回答
Flink
kafka
消费者从特定分区获取消息
、
、
我们希望在读取来自
kafka
的消息时实现并行性。因此,我们希望在flinkkafkaconsumer中指定分区编号。它将读取
kafka
中所有分区的消息,而不是特定的分区号。
浏览 139
提问于2020-07-09
得票数 1
1
回答
如何
存储主题上的数据,这些数据将通过生产者作为消息传递,以便可以加载到相应列的数据库中
、
到目前为止,我使用
kafka
spring在this blog上生成了一条主题消息。
如何
实现上述功能?
浏览 12
提问于2021-08-25
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
如何设计Kafka?
Kafka 安装及快速入门
不想厂商收渔翁之利,Kafka 团队修改 KSQL 开源许可
不想云厂商坐收渔翁之利,Kafka 团队修改 KSQL 开源许可
这可能是北半球最暖的Kafka Connect数据管道教程:3
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
活动推荐
运营活动
广告
关闭
领券