腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(1398)
视频
沙龙
1
回答
Meltano
Kafka
Monk.io
集成
、
、
、
我正在尝试
Monk.io
和
Kafka
-
Meltano
集成
。因此,我想创建一个
Monk.io
Kafka
集群,并在
Meltano
上提供一个新的连接。我正在使用https://github.com/lensesio/fast-data-dev for
Kafka
env。什么是最好的方法,并且最有意义?我计划这样做:创建
Kafka
和
Meltano
的runnables,并为<em
浏览 15
提问于2021-02-02
得票数 0
回答已采纳
2
回答
应用转换后,需要将数据从Hadoop加载到Druid。如果我使用Spark,我们可以直接从Spark RDD或dataframe加载数据到Druid吗?
、
、
我在hive表中显示了数据。在将数据加载到druid之前,我想应用一系列的转换。所以有一些方法,但我不太确定。1.转换后保存该表,然后通过hadoop摄取方式进行批量加载。但我希望避免在服务器上进行额外的写入。2.使用宁静。但它是针对Spark Streaming的,仅适用于Scala和Java,而不适用于Python。我说的对吗?
浏览 40
提问于2019-11-04
得票数 2
2
回答
springboot如何
集成
Ckafka,必须使用
kafka
-client吗?
浏览 238
提问于2023-02-27
2
回答
pyspark是否支持spark-streaming-
kafka
-0-10 lib?
、
、
我的
kafka
集群版本是0.10.0.0,我想使用pyspark流来读取
kafka
数据。但是在Spark Streaming +
Kafka
集成
指南中,没有python代码示例。那么pyspark可以使用spark-streaming
kafka
-0-10来
集成
kafka
吗? 提前感谢您的帮助!
浏览 11
提问于2017-08-05
得票数 0
1
回答
如何检查当前环境是否为spring容器?
、
、
我设计了一个组件来收集应用程序运行时数据,这些数据通过
Kafka
发送到分析服务器。在大多数情况下,应用程序会
集成
Kafka
。为了避免连接到同一个
Kafka
两次,我需要确定应用程序是否使用
Kafka
。如果应用程序使用
Kafka
,我会直接重用连接。如果app
集成
了spring-
kafka
,我应该怎么做?
浏览 1
提问于2021-05-20
得票数 0
1
回答
Kafka
与Spring框架的连接
、
、
、
、
有没有人知道Spring Boot与
Kafka
Connect的
集成
?有一个spring-
kafka
项目,我认为它与
Kafka
客户端进行了很好的
集成
,但没有连接和流API。
浏览 2
提问于2017-08-09
得票数 7
1
回答
如何进行
集成
测试和端到端测试?
、
、
、
、
,
kafka
); // MOQ all the three这里我们有6个外部组件要
集成
到我们的应用程序中我的问题是我们如何处理
集成
测试?
集成
测试是否处理对象测试?我认为单元测试处理对象测试,所以
集成
必须处理外部组件测试。如果我们想编写
集成
测试,我该如何处理?// Setup
kafka
real and oth
浏览 0
提问于2018-01-17
得票数 0
回答已采纳
1
回答
AWS事件桥在卡夫卡消费灯中的作用是什么?
、
、
、
根据现有的文章/博客,AWS现在支持lambdas的自身承载的
kafka
实现。此外,还存在预定的lambda。但有人知道事件桥站在哪里吗?
浏览 9
提问于2022-06-14
得票数 0
回答已采纳
2
回答
为开发人员/
集成
测试环境设置Apache
我正在寻找关于如何在开发人员&
集成
测试环境上设置和运行Apache的建议和指导。我必须求助于某种无节制的解决方案吗?
浏览 2
提问于2017-03-07
得票数 9
回答已采纳
1
回答
对
kafka
消费者的注释
、
、
、
、
示例- @KafkaListener(topics = "topicname",groupId = "groupid") //函数代码在这里 同样,在使用Confluent.
Kafka
的C#中是否也有相同的注释
浏览 20
提问于2021-03-24
得票数 0
1
回答
如何在springboot中为每个主题动态创建单独的
Kafka
监听器?
、
、
、
、
我是Spring和
Kafka
的新手。我正在做一个使用SpringBoot-
kafka
的用例,允许用户在运行时创建
kafka
主题。spring应用程序期望在运行时以编程方式订阅这些主题。到目前为止,我所知道的是,
Kafka
listener是设计时,因此在启动之前需要指定主题。有没有办法在SpringBoot-
Kafka
集成
中动态订阅
kafka
主题?已引用此 我计划实现的当前方法是,不要使用Spring-
Kafka
集成
,而是自己使用这里
浏览 0
提问于2017-01-08
得票数 11
1
回答
是否有连接到Apache Spark的OSI PI适配器或连接器?
、
、
、
如何将OSI PI中的数据导入Apache Spark?特别是在数据流传输的情况下?如果没有直接适配器,有什么替代方案可以将osi pi中的数据转换为spark?
浏览 2
提问于2015-08-06
得票数 0
1
回答
卡夫卡连接与溪流对决
、
、
我试着理解Connect给你买了什么流不给你的东西。我们有一个应用程序的一部分,我们想要使用一个主题并写到mariadb。为什么这是个坏主意?JDBC连接器给你买了什么?
浏览 0
提问于2019-01-18
得票数 11
回答已采纳
1
回答
Spring
集成
- ActiveMQ到
Kafka
、
、
、
、
我目前正在尝试编写一个适配器,它将使用来自ActiveMQ的消息并将其发布到
Kafka
。ALso,另一个要求是仅当
kafka
发送/发布成功时才向活动mq发送确认。是否可以使用spring
集成
将ack发送回activemq?请注意,我的技术架构师不赞成使用C
浏览 10
提问于2017-07-05
得票数 0
回答已采纳
2
回答
将
Kafka
生产者和消费者
集成
到web应用程序中
、
我正在使用春季
集成
-卡夫卡最新版本。在Spring中使用相同的代码时,我无法生成消息。但是,在独立的Java程序中使用它是有效的。proposition=5}, headers={timestamp=1425653206240, id=eccb00b0-6617-b5c4-6de0-45a08730041e, messageKey=1,
kafka
_topic定义了两个资源,一个是使用
Kafka
本地Java,它正在工作。其他资源正在使用spring
集成
,而且它不起作用。="http://
浏览 1
提问于2015-03-05
得票数 1
回答已采纳
1
回答
如果
Kafka
和Zookeeper没有运行,为什么Maven Clean安装不会完成?
、
、
、
、
为了学习Apache
Kafka
,我开发了一个Spring Boot应用程序,如果我向调用
Kafka
发送方法的控制器发送POST请求,它会向KafkaTemplate主题发送消息。我正在运行Ubuntu19.04,并在本地成功设置和安装了
Kafka
和Zookeeper。一切都很好。Connection to node -
浏览 79
提问于2019-07-22
得票数 1
回答已采纳
1
回答
如何在Wiremock
集成
测试中模拟SpringBoot的MessageChannel中的发送方法
、
、
、
、
应用程序正在使用MessageChannel向
Kafka
发送一些消息。例如:this.messageChannel.send(消息)。我想在
集成
测试中模拟这个消息通道调用,这样消息就不会发送到
Kafka
。目前正在使用Wiremock进行Spring
集成
测试。 请给我建议模拟MessageChannel发送方法的方法
浏览 27
提问于2021-08-06
得票数 0
1
回答
Apache
Kafka
与HTTP API
我刚接触Apache
Kafka
和它的与API相关的流服务,但想知道是否有任何正式的文档来获取摄取所需的初始原始数据?从本质上讲,我想尝试构建一个初级的密码交易机器人,但我的印象是http API可能比与
Kafka
Streams
集成
的API具有更多的延迟。例如,我知道RapidAPI有一个可以访问的http库,可以帮助提取数据,但我不确定如果我想通过
Kafka
Streams摄取数据,是否有类似的东西。我试着在Google上挖掘,但不是很清楚
Kafka
Streams采用了什么API或源数据,或者它们是
浏览 0
提问于2021-06-05
得票数 0
1
回答
最好的Spring Rest服务是作为桥梁还是Kafta与其Rest接口的直接
集成
?
、
、
我有一个项目的要求,其中我有一个源系统,将产生的事件,我需要
集成
到卡夫卡。现在我想从以下几个方面来探索它: 1.让java rest服务充当我的源代码和
Kafka
之间的桥梁是最好的吗?有什么最好的框架可以实现这样的
集成
。2.是否最好使用
Kafka
的Rest接口将我的源码直接
集成
到
Kafka
?
浏览 8
提问于2019-12-13
得票数 1
1
回答
星火流1.6与
kafka
0.11
、
我已经将
kafka
broker从0.8升级到0.11,现在我正在尝试升级星火流作业代码,使其与使用spark 1.6.2-的新的
kafka
-I am兼容。我发现唯一有用的文章是,但是它提到了spark 2.2和
kafka
0.10,但我有句话说 但是,由于新的
集成
使用的是新的
Kafka
消费API而不是简单的API,所以在使用上有明显的差异。此版本的
集成
被标记为实验性的,因此API可能会发生更改。是否有人曾尝试将星火流1.6与
kafka
0.11
集成</em
浏览 3
提问于2017-10-01
得票数 2
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
SpringBoot集成Kafka
JStorm kafka集成解析
linux安装flume和集成kafka测试
Spark Structured Streaming 入门学习:集成Kafka
Spark Streaming和Kafka集成深入浅出
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券