腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
使用
Kafka
协议
连接
Camel
和
EventHubs
apache-kafka
、
apache-camel
、
azure-eventhub
我正在尝试将消息从
Camel
路由到Azure
EventHubs
。
EventHubs
命名空间是
使用
Kafka
enabled标志创建的。String eventHubsPassword = "org.apache.
kafka
.common.security.plain.PlainLoginModule " + "required是事件中心的名称,eventHubsKafkaBrokers类似于mynamespace.servicebus.wi
浏览 34
提问于2019-07-04
得票数 0
回答已采纳
1
回答
消息没有被消耗掉
apache-kafka
、
apache-camel
、
azure-eventhub
、
spring-camel
我在Spring的application.properties文件中添加了以下配置
和
Camel
实现,但是消息并没有被消耗。我错过任何配置了吗?有没有
使用
kafka
协议
和
Camel
从Azure事件中心实现消费者的指针?NAMESPACENAME.servicebus.windows.net:9093sasl.mechanism=PLAIN sasl.jaas.config=org.apache.
kafka
.commo
浏览 4
提问于2021-10-11
得票数 0
回答已采纳
2
回答
如何在Amazon上运行
Kafka
Camel
连接
器
amazon-web-services
、
apache-kafka
、
apache-camel
、
azure-eventhub
、
amazon-msk
上下文:,我遵循了这个链接,它是正确设置
和
工作的。我能够通过两个单独的EC2实例发送
和
接收消息,这两个实例都
使用
相同的
Kafka
集群(我的MSK集群)。现在,我想建立一个从
Eventhubs
到AWS Firehose的数据管道,如下所示: Azure -> Eventhub to-
Kafka
Camel
Connector -> -> ->
Kafka
to- Kinesis Fire32个
Camel
<em
浏览 7
提问于2021-05-03
得票数 1
回答已采纳
1
回答
如何
使用
init脚本以编程方式将Maven库安装到集群中?
maven
、
cluster-computing
、
databricks
、
azure-databricks
它要求
使用
预先制作的init脚本来完成此操作,然后在配置集群时在UI中选择该脚本。我正在尝试将com.microsoft.azure:azure-
eventhubs
-spark_2.12:2.3.18安装到Azure上的集群中。在文档示例(它正在安装postgresql驱动程序)之后,它们
使用
以下命令生成init脚本: dbutils.fs.put("/databricks/scripts/postgresql-install.sh
浏览 13
提问于2022-05-03
得票数 1
回答已采纳
1
回答
带有EventHub的Delta表
pyspark
、
databricks
、
azure-eventhub
、
delta-live-tables
我正在尝试
使用
delta实时表来创建eventhub流,但我在安装库时遇到了困难。是否可以
使用
使用
sh /pip的Delta表安装maven库?我想安装com.microsoft.azure:azure-
eventhubs
-spark_2.12:2.3.17
浏览 23
提问于2022-05-24
得票数 4
回答已采纳
1
回答
Camel
Kafka
.NET
连接
器
apache-kafka
、
apache-camel
我是新来的骆驼
和
卡夫卡。我一直在阅读一些关于
Camel
的文档,并遇到了this repository,其中有许多
连接
器的链接。这些似乎是主存储源的
连接
器。如果我需要从.NET
连接
,在将数据提交到数据库之前提取数据并对其进行处理,该怎么办?我觉得我不知何故错过了要点,因为我没有看到任何类型的C#
连接
器。
浏览 17
提问于2020-12-10
得票数 1
1
回答
如何
使用
JAVA程序将消息从文件路由到Azure事件中心
java
、
azure
、
events
、
apache-camel
//SimpleRouteBuilder public class SimpleRouteBuilder文件必须由
Camel
读取并路由到Azure Event Hub
浏览 13
提问于2020-10-12
得票数 0
1
回答
从Azure物联网集线器来源的火花流作业数据库的延迟
python
、
apache-spark
、
azure-databricks
、
spark-structured-streaming
、
azure-iot-hub
我一直在
使用
星火流作业,
使用
Python on Databricks从Azure IotHub加载源。然而,我注意到,当我们有大量接收到的帧时,任务就会很长,所以我们有延迟,我们知道当我们查看这些度量标准时,CPU
和
内存是而不是,它们的容量是100%的。
浏览 3
提问于2021-12-28
得票数 1
1
回答
用于活动中心的kafkacat
azure
、
apache-kafka
、
azure-eventhub
嗨,我试着在我的一个azure虚拟机中
使用
kafkacat检查到eventhub的
连接
,我给出了以下参数(填写我的hab名称
和
所有): kafkacat \ -b <your-hub-name>.servicebus.windows.net我是否必须创建一个主题
和
SAS身份验证并获取他的密钥?
浏览 24
提问于2020-07-07
得票数 2
1
回答
使用
azure事件集线器源
连接
器时以字节形式返回的Avro架构
azure
、
apache-kafka
、
apache-kafka-connect
、
confluent-platform
、
confluent-schema-registry
我们现在
使用
的是confluent 6.1.0,并尝试
连接
到Azure even Hub。我们可以看到即将到来的数据,但当进入模式时,它总是以字节显示。谁能给我们一些关于如何解决这个问题的想法?{ "connector
浏览 4
提问于2021-10-20
得票数 0
1
回答
不支持
Camel
-
Kafka
安全
协议
SASL_PLAINTEXT
java
、
apache-kafka
、
apache-camel
、
kerberos
、
cloudera
我需要
使用
身份验证
协议
Kerberos
使用
Camel
将ActiveMQ消息路由到
Kafka
(Cloudera)。ActiveMQ v5.15.4 Kerberos的SASL_SSL 另一方面,当我试图在
Camel
中
使用
SA
浏览 0
提问于2018-06-23
得票数 1
1
回答
我能用
Camel
kafka
连接
器将一条消息拆分成不同的消息并发送给
Kafka
吗?
apache-camel
、
apache-kafka-connect
、
spring-camel
我试图读取一个文件,并
使用
Camel
kafka
连接
器将数据发送给
kafka
,但我需要将文件拆分为多条消息,并将它们分别发送给
Kafka
。是否可以
使用
camel
卡夫卡
连接
器、
camel
文件-
kafka
连接
器将数据分拆并单独发送给
kafka
? 提前谢谢。
浏览 10
提问于2022-01-25
得票数 1
1
回答
如何处理启动端点时
Camel
DSL中的异常
和
重试路由启动
spring
、
apache-camel
、
dsl
我正在
使用
在
camel
DSL中配置的
kafka
消费者来监听
Kafka
主题。还有另一个安装了
kafka
的应用程序(服务器),它正在生成有关此主题的数据。<
camel
:endpoint id='docInfo' uri='
kafka
:${
camel
.
kafka
_broker}?topic=${
camel
.
kafka
_topic}&zookeeperConne
浏览 4
提问于2016-05-10
得票数 0
2
回答
天蓝色
和
弹簧云-蔚蓝-河流-粘合剂的区别是什么?
azure
、
spring-boot
、
spring-kafka
、
amqp
、
azure-eventhub
我的要求是
使用
Azure事件集线器
使用
Spring的一个简单的发布子。这两者有什么区别呢?
浏览 13
提问于2020-08-24
得票数 1
回答已采纳
2
回答
为什么
Camel
Kafka
-Rabbitmq
连接
器将我的邮件转换为无法读取的格式?
apache-kafka
、
rabbitmq
、
apache-camel
、
apache-kafka-connect
我的目标是在rabbitmq交换队列
和
kafka
主题之间建立一个
连接
器。我按照这个指南来设置
连接
器:https://
camel
.apache.org/
camel
-
kafka
-connector/latest/try-it-out-locally.html。我从源代码https://github.com/apache/
camel
-
kafka
-con
浏览 11
提问于2020-09-25
得票数 1
回答已采纳
1
回答
在从spark structured streaming推送到Azure事件中心(
Kafka
端点)之前对事件进行批量处理
apache-spark
、
apache-kafka
、
spark-structured-streaming
、
azure-eventhub
当我调用writeStream().format("
kafka
")时,它对
kafka
进行了1000次调用,以传输这些单独的行条目。是否可以批量处理这1000条消息并对Event hub (
使用
KAFKA
端点启用)进行一次调用? 通过
使用
eventhub客户端库
和
调用createBatch()方法,我尝试了下面的代码。但它选择了一个字符串条目的集合,为此,我需要在dataframe上执行foreachBatch或collect才能
使用
该库。bool
浏览 16
提问于2021-08-03
得票数 0
2
回答
Camel
:检测
Kafka
错误IP
java
、
apache-camel
、
apache-kafka
我正在将
Kafka
配置为我的RouteBuilder中的源码。我的目标是处理
Kafka
断开
连接
的问题。)); }); } }我提供了错误的主
浏览 2
提问于2017-11-14
得票数 2
1
回答
Spring DSL中路由的`to` url参数中为什么没有插入头值?
java
、
apache-camel
、
mqtt
、
camel-spring-dsl
uri="
kafka
://mqtt?brokers=localhost:9092"/> <to uri=&
浏览 19
提问于2021-10-18
得票数 0
回答已采纳
2
回答
如何序列化Azure事件集线器事件属性?
azure
、
azure-eventhub
我希望生成
和
发送EventData对象,这些对象在字典中设置了各种特定于应用程序的属性。
浏览 1
提问于2019-06-21
得票数 1
回答已采纳
1
回答
在局域网中
使用
CEP引擎
和
流数据生成器传输数据的最佳方式是什么?
java
、
complex-event-processing
我刚接触复杂事件处理( CEP )系统,
使用
一个名为Esper的CEP引擎来检测智能建筑中的事件模式。不同的传感器为它们假设并实现了数据生成器。我想测量我的系统的性能。我应该
使用
UDP还是TCP ??需要线程化吗?因为假设了很多传感器。
浏览 0
提问于2014-09-17
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
【行业资讯】Apache Camel 3.6.0 发布
“集成架构”我们得谈谈 Apache Camel集成框架
“集成架构”我们得谈谈 Apache Camel
Apache软件基金会现价值 200 亿美元
Java近期新闻:GlassFish 7.0、Payara平台、Apache NetBeans 16
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券