腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
在
Kafka
上
获取
Storm
runningo
apache-kafka
、
apache-storm
我有一个问题,正在执行一个样本来连接
storm
和
kafka
。我成功地让
kafka
运行起来了。下一步将是连接
storm
。 这是示例代码。at org.apache.
storm
.
kafka
.KafkaUtils.getOffset(KafkaUtils.java:81) ~[
storm
-
kafka
-1.2.2.jar:1.2.2]at org.apache.
storm
.
kafka
.KafkaUtils.getOffset
浏览 34
提问于2019-06-10
得票数 0
回答已采纳
1
回答
如何让第一个
Storm
Kafka
演示程序工作?
apache-kafka
、
apache-storm
提交一个简单的第一个
Storm
Topology让我抓狂。首先,当我试图
在
安装
storm
的远程VM
上
运行它时,连接被拒绝。我明白,我必须在本地集群
上
运行它。Spring Boot和Spring
Kafka
(
Kafka
作品)。-- https://mvnrepository.com/artifact/org.apache.
storm
/
storm
-
kafka
-->
浏览 14
提问于2019-06-16
得票数 1
回答已采纳
2
回答
在
Kafka
Spout中使用新的
Kafka
版本2.1.0和Apache
Storm
1.2.2
获取
ClassNotFoundException
apache-kafka
、
apache-storm
在
使用新的
Kafka
版本2.1.0和
Storm
版本1.2.2开始使用
Kafka
Spout开始拓扑时,获得了一个java.lang.ClassNotFoundException:
kafka
.api.OffsetRequest当我使用
Kafka
版本0.10.0.1时,我没有得到这个。你们能帮帮忙吗,因为我想上最新的
Kafka
版本? 我已经尝试了所有最新的
kafka
版本,从2.*开始。但不是works.Caused by: java.lang.Class
浏览 16
提问于2019-02-07
得票数 0
回答已采纳
1
回答
从
Kafka
获取
消息时缓冲区下溢
apache-kafka
、
apache-storm
、
trident
我正在设置
storm
用于流处理,我的三叉树喷嘴正在从
kafka
主题中
获取
数据,但在从
kafka
中
获取
消息时,我不断地
获取
BufferUnderFlowException: 位于backtype.
storm
.utils.DisruptorQueue.consumeBatchToCursorjava.nio.BufferUnderflowException由: java.lang.RuntimeException: java.nio.BufferUnderflowExcep
浏览 2
提问于2016-05-31
得票数 0
1
回答
Storm
:
在
apache拓扑中将startOffsetTime设置为
kafka
.api.OffsetRequest.LatestTime
apache-kafka
、
apache-storm
目前,strom从一开始就
获取
消息,但我希望它只从
kafka
获取
最新消息。 - id: "stringScheme" - ref: "stringScheme" c
浏览 0
提问于2018-05-27
得票数 0
回答已采纳
1
回答
如何使用新的
kafka
Consumer API编写最简单的
Kafka
spout?
apache-kafka
、
apache-storm
、
producer-consumer
、
kafka-consumer-api
喜欢
storm
-
kafka
-client,我曾经使用
storm
-
kafka
-client,但是不能很好地工作,并且写了一个新的spout也不能工作。谁能帮我写一个卡夫卡喷嘴的样本。
浏览 5
提问于2016-09-27
得票数 0
1
回答
NoClassDefFoundError: org/apache/
storm
/
kafka
/spout/KafkaSpoutConfig
java
、
maven
、
apache-kafka
、
apache-storm
我目前正在学习如何使用apache和apache,通过遵循OpenClassRoom提供的课程,我的问题非常类似于我们可以找到的和.I试图用这些帖子
上
提供的信息来解决我的问题,但是没有任何改变,我仍然有同样的错误我可以
在
eclipse
上
编译代码,并且可以使用mvn package命令,没有任何问题。我把我找到的所有信息都放到了
kafka
和
storm
的pom.xml里。任何建议都会对我有很大帮助。>
storm
-
kafka
-client</artifa
浏览 5
提问于2022-05-30
得票数 1
回答已采纳
1
回答
为什么
在
libraryDependencies中不使用%%时,Scala版本会添加到URL中?
sbt
我试图将中的依赖项更改为至构建失败是因
浏览 0
提问于2014-05-06
得票数 1
回答已采纳
1
回答
在
hortonworks流分析管理器中
获取
InstantiationException
streaming
、
hdf
、
hortonworks-sam
在
尝试使用HDF 3.0.0沙箱运行SAM拓扑时,我得到了以下异常。我
在
画布
上
只有2个组件。1)从
Kafka
Topic
获取
输入2)将topic的内容写入HDFS Sink。org.apache.
storm
.
kafka
.bolt.selector.DefaultTopicSelector :java.lang.InstantiationException 场景背后的引擎是
Storm
在
尝试执行该流时,发生了上述错误。我正在尝试
获
浏览 0
提问于2017-07-16
得票数 0
0
回答
org/apache/
kafka
/common/requests/AbstractResponse :NoClassDefFoundError
apache-kafka
、
apache-storm
在
我们的项目中,我们使用
storm
来处理实时的
Kafka
主题
Storm
-
Kafka
version: 1.0.2
Kafka
-Version: 0.11.0.1at org.apache.
storm
.
kafka
.KafkaConfig.<init>(KafkaConfig.java:36) ~[
storm
-
kafka
-1.0.2.jar:1.0
浏览 15
提问于2017-11-24
得票数 1
1
回答
Storm
-
Kafka
spout未在zookeeper集群中创建节点。
apache-kafka
、
apache-storm
我用
storm
-
kafka
来标记
storm
0.10和
kafka
0.9.0.0。每当我
在
集群
上
运行我的拓扑时,它都会从头开始读取,尽管我将属性文件中的zkRoot和消费者groupId设置为-
kafka
.topic=onboarding-mail-topic
kafka
.zkRoot=/
kafka
-
storm
浏览 1
提问于2016-03-03
得票数 2
2
回答
集成
Kafka
和HBase的最佳实践
apache-spark
、
hbase
、
apache-kafka
、
apache-storm
、
flume
将
Kafka
中的流数据“导入”到HBase中的最佳实践是什么? 使用案例如下:将车辆传感器数据流式传输到
Kafka
。然后,必须对这些传感器数据进行转换(即,将protobuf反序列化为人类可读的数据),并将其存储
在
HBase中。1)您推荐哪个工具集(如
Kafka
--> Flume --> HBase、
Kafka
-->
Storm
--> HBase、
Kafka
--> Spark Streaming --> HBase、
K
浏览 1
提问于2015-08-18
得票数 6
1
回答
Storm
Kafka
Spout未在本地集群中提交偏移量,spout重复检索相同的消息
apache-kafka
、
apache-storm
、
kafka-consumer-api
我已经设置了风暴拓扑,它从
kafka
服务器
获取
输入数据。我使用
kafka
-
storm
包来
获取
数据。我已经
在
本地集群中成功实现了
kafka
服务器和
storm
拓扑的连接,但在从
kafka
服务器检索数据时遇到了一些问题。即使我设置了spoutconfig.forceFromStart=false和spoutconfig.startOffsetTime =-1,
kafka
Spout也会在运行时重复检索相同的消息 注意:
浏览 0
提问于2015-02-06
得票数 1
1
回答
Intellij IDEA maven :无法解析符号"backtype“
java
、
xml
、
maven
、
intellij-idea
、
apache-storm
当我
在
IDEA
上
做项目时,我发现maven没有下载我需要的所有类(实际
上
大部分的类)。pom.xml是 <
storm
.version>1.0.2</
storm
.version> <scala.version>2.1
浏览 7
提问于2016-12-01
得票数 0
回答已采纳
1
回答
Storm
bolt无输出
apache-storm
我有一个非常简单的
Storm
bolt,它从
Kafka
spout中
获取
输入,应该只写入标准输出。它扩展了BaseRichBolt。collector_.ack(input);它是这样连起来的: builder_.setSpout("
kafka
-spout",kafkaSpout,1);
浏览 0
提问于2015-07-10
得票数 2
2
回答
KafkaSpout元组重放引发空指针异常
apache-kafka
、
apache-storm
、
bigdata
我使用
storm
1.0.1和
Kafka
0.10.0.0以及
storm
-
kafka
-client 1.0.3。 at org.apache.
storm
.
kafka
.spout.KafkaSpout.pollKafkaBro
浏览 2
提问于2017-03-31
得票数 0
2
回答
重新启动
Storm
时再次处理卡夫卡的所有预处理记录
java
、
apache-kafka
、
apache-storm
但是,当我重新启动
Storm
时,它也会读取之前处理过的
Kafka
记录。
在
重新启动时,我不想处理以前处理过的记录。StringScheme()); builder.setSpout("
kafka
-spoutKafkaSpout(kafkaSpoutConfig)); builder.setBolt("word-spitter", new SplitB
浏览 0
提问于2019-08-25
得票数 2
回答已采纳
3
回答
KafkaSpout为log4j抛出NoClassDefFoundError
apache-kafka
、
apache-storm
由于某些原因,当我试图
在
Storm
集群
上
运行拓扑时,会出现以下错误: at
storm
.
kafka
.KafkaUtils.getOffset(KafkaUtils.java:77) at
storm
.
kafka
.KafkaUt
浏览 5
提问于2015-10-10
得票数 5
回答已采纳
1
回答
“卡夫卡喷泉”和“卡夫卡消费者”有什么区别?
apache-kafka
、
apache-storm
-or,如果我使用一个消费者提取数据,然后使用一个“setSpout”接收数据,那么如果我只是使用一个"
Kafka
“,然后将它添加到的setSpout()函数中,两者之间的区别是什么?
浏览 1
提问于2016-07-01
得票数 4
回答已采纳
2
回答
将数据从
Kafka
实时流式传输到Cassandra
cassandra
、
apache-kafka
将
Kafka
中的日期写入Cassandra的最佳方式是什么?我希望它是一个解决的问题,但似乎没有一个标准的适配器。许多人似乎使用
Storm
来读取
Kafka
,然后写入Cassandra,但
storm
似乎对简单的ETL操作有点杀伤力。
浏览 2
提问于2015-04-15
得票数 9
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
全链路监控扩展篇:storm从1.0.2 升级到 1.2.2全流程-下
storm+kafka+redis的实时订单流
在Linux上通过可写文件获取root权限的多种方式
Flume+Kafka+Storm+Redis构建大数据实时处理系统
全链路监控扩展篇:storm从1.0.2 升级到 1.2.2全流程-上
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
活动推荐
运营活动
广告
关闭
领券