1回答
展示了如何在kafka consumer中使用多线程：topicCountMap.putstreams) { threadNumber++;但风暴中的KafkaSpout似乎并不是多线程的。在KafkaSpout中可以使用多任
浏览 11提问于2017-08-29得票数 0
1回答
我使用KafkaSpout如下所示：String topic = "sentences";
KafkaSpoutkafkaSpout = new KafkaSpout(spou
浏览 0提问于2016-05-18得票数 0
回答已采纳
1回答
builder.setBolt("Bolt1", bolt1).fieldsGrouping("Bolt1", new Fields("id"));
是否保证使用id x的元组总是按照螺栓的顺序进行处理
浏览 0提问于2017-11-15得票数 1
回答已采纳
1回答
从一段时间以来，我一直在尝试了解如何创建一组订阅单个主题的kafkaspout。我发现一些引用spoutconfig中的id的来源可以用作组id。我的主要问题是如何知道创建的spout是否作为一个组。我的代码是这样的 return <
浏览 0提问于2016-10-17得票数 0
我正在使用ApacheStorm0.10.0-beta1，并开始将一些拓扑转换为Flux。我决定从一个简单的拓扑开始，从一个Kafka队列中读取并写入一个不同的Kafka队列。我得到了这个错误，我有一个困难的时间找出什么是错的。拓扑yaml文件遵循错误。388 [main] INFO o.a.s.f.p.FluxParser - loading YAML from input stream...
391 [main] INFO o.a.s.f.p.FluxParser - Not pe
浏览 4提问于2015-08-20得票数 0
回答已采纳
喜欢storm-kafka-client，我曾经使用storm-kafka-client，但是不能很好地工作，并且写了一个新的spout也不能工作。谁能帮我写一个卡夫卡喷嘴的样本。
浏览 5提问于2016-09-27得票数 0
1回答
<init>(ZkState.java:62) ~[storm-kafka-0.9.2-incubating.jar:0.9.2-incubating] at backtype.storm.daemon.executor<init>(ZkState.java:62) ~[storm-kafka-0.
浏览 6提问于2015-05-16得票数 10
回答已采纳
要配置一个kafkaSpout，它需要BrokerHosts，而后者又需要一个zookeeper主机。TopologyConstants.KAFKA_QUEUE.SOURCE,问题是，如果我有一个zookeeper quorum (由3个zk服务器组成的集群)，我如何
浏览 16提问于2018-02-20得票数 0
回答已采纳
为此，我有一个KafkaSpout，它将发出流到Bolts(它有我的CEP查询)来过滤流。我在Storm中使用默认的KafkaSpout。对配置进行一些优化可以做到这一点，或者我是否需要为此定制KafkaSpout？TopologyBuilder builder =新的TopologyBuilder()；
新<
浏览 1提问于2019-03-05得票数 0
回答已采纳
apache KafkaSpout是否有在其订阅的源主题之间设置优先级的概念？例如，如果KafkaSpout订阅了主题t1、t2、t3，那么是否有一种方法可以控制t1中的70%、t2中的20%和t3中的10%，如果主题t1中没有任何消息，那么是否可以将t1的资源分配给t2等等？
浏览 0提问于2018-07-24得票数 0
回答已采纳
1回答
我是否需要创建单独的流，并再次将每个元组传递给同一组函数。像下面这样吗？"Test1");OpaqueTridentKafkaSpout kafkaSpout1= new OpaqueTridentKafkaSpout(spoutConf1);
topology.newStream("event", kafkaSpout).each(new Fields(documen
浏览 4提问于2015-07-16得票数 0
该算法使用KafkaSpout从卡夫卡队列中读取数据。zookeeper_root, consumer_group_id); KafkaSpoutkafkaSpout = new KafkaSpout(kafkaConfig); //builder.se
浏览 0提问于2015-12-17得票数 1
1回答
我曾经在上工作过，并开发了一个使用本地文本文件作为输入源的basic程序。但现在我必须处理来自外部系统的连续流数据。为此，Kafka是最好的选择。
浏览 2提问于2013-11-05得票数 2
1回答
如何将Strom spout设置为可靠Is kafkaSpout reliable by default
How to change thereliablity in kafkaSpout
浏览 2提问于2016-06-12得票数 2
我们想从卡夫卡主题的种子URL馈送到基于StormCrawler的项目。有必要更换风暴爬虫吗？
浏览 5提问于2020-10-14得票数 0
zookeeper_root, consumer_group_id);KafkaSpoutkafkaSpout = new KafkaSpout(kafkaConfig);MongoClient mongoClient = new MongoClient( "new MongoInsertBolt(iotSampleColl);
TopologyBuil
浏览 3提问于2016-01-04得票数 0
回答已采纳
我正在尝试从KafkaSpout读取kafka消息，并从json中设置从该消息解析的元组值。实际上，我正在创建一个额外的Bolt，它用来自KafkaSpout的json字符串解析一个名为"value“的元组字段。是否可以在Spout中设置这些值？class ScanConfigKafkaSpout(kafkaUrl: String, kafkaGroup: String, kafkaTopic: String) : KafkaSpout<String
浏览 5提问于2021-06-30得票数 0
2回答
我们的Storm拓扑中有一个场景，其中KafkaSpouts无法使用来自主题的任何消息。Spout连续记录相同的警告消息：
2016-10-26 11:11:31.070 o.a.s.k.KafkaUtils [WARN] Partition{host=somehost.org:9092, topic=my-topic, partition=0} Got fetch request with offset out of range: [3]
2016-10-26 11:11:31.078 o.a.s.k.KafkaUtils [WARN] Part
浏览 2提问于2016-10-26得票数 4
回答已采纳
1回答
最近我遇到了一个非常奇怪的问题。storm集群有3台机器。拓扑结构是这样的，Kafka Spout A -> bolt B -> Bolt。我已经确认了每个螺栓中的所有元组，即使可能在螺栓内部抛出异常(在螺栓执行方法中，我尝试捕获所有异常，最后确认元组)。但这里发生了奇怪的事情。我打印了喷嘴的日志，在一台机器上，所有的元组都被喷嘴破解了，但在另外两台机器上，几乎所有的元组都失败了。60秒后，元组一次又一次地重放。“几乎”表示在开始时，其他两台机器上的所有元组都失败了。一段时间后，在两台机器上有少量的元组。
由于超时，元组绝对会失败。但我真的不知道他们为什么会超时。根据我打印的日志，
浏览 0提问于2017-06-08得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
