回答情况：
提问时间：
问题标签：
请有人解释一下EasyNetQ.Topology.Queue类型的构造函数的参数EasyNetQ.Topology.Queue的用法。
注意:需要实例化此类型，以便使用Advanced删除队列。
浏览 10提问于2014-02-17得票数 2
回答已采纳
我正在使用storm jar类向‘`nimbus’提交拓扑。它在本地运行良好，但在远程集群上，它说它无法加载主类。下面是错误SLF4J: Found binding in [jar:file:/usr/local/storm-0.9.0.1/lib/logback-classic-1.0.6.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/tmp/storm-s
浏览 3提问于2014-02-27得票数 4
我正在尝试设置TOPOLOGY_MAX_SPOUT_PENDING参数来限制要发送的消息的数量。但我看到它没有任何效果。是因为我在一个nextTuple()方法中发出了所有的元组吗？
浏览 1修改于2015-11-27得票数 3
我已经追溯了一点，我可以看到，在上，topology.s.promiseLibrary是未定义的。我不知道我该怎么做才能导致这件事。奇怪的是，定义了topology.s.options.promiseLibrary。我不确定我是否做错了什么来配置它。我没有更改我的代码(我已经恢复到以前工作过的代码)。我的节点版本是v9.2.0。const Promise = topology.s.promiseLibrary;
这是个虫子吗？可能是什么原因？看起来可能是外部原因，但我不知道该在哪里继续我的搜索。topology.s.pro
浏览 0修改于2018-06-12得票数 0
让我们假设groupby函数在kafka streams中不可用。我是否可以执行以下操作来获取字数并在其上构建一个KTable？请注意，我在拓扑中使用了两次"word-count-topic“。我有一个用例，我想要迭代地构建一些东西，对于下一个流事件，我想要查找以前的值并基于事件更新它。我希望在构建Ktable的同一主题中保持最新的值。 KTable<String,Long> wordCountTable = builder.table("word-count-topic",Consumed.with(Serdes.String(), Serdes.Lon
浏览 18修改于2020-08-26得票数 0
回答已采纳
resources/words.txtException in thread "main" java.lang.NoSuchMethodError: backtype.storm.topology.TopologyBuilder.setBolt(Ljava/lang/String;Lbacktype/storm/topology/IRichBolt;Ljava/lang/Integer;)Lbacktype/storm/
浏览 2提问于2014-05-08得票数 2
下午好，我正在关注风暴启动器WordCountTopology 。作为参考，这里有一些Java文件。public class WordCountTopology { super("python", "splitsentence.py");public void declareOutputFields(OutputFi
浏览 1修改于2015-10-20得票数 0
我想在Tensorflow中导入keras.engine.topology。如果我想使用tensorflow版本的Keras，我会在每次Keras导入的开头添加Tensorflow一词。tensorflow.keras.layers import Dense, Dropout, Inputfrom tensorflow.keras.engine.topology
浏览 3提问于2018-07-14得票数 20
回答已采纳
keras_vggface.vggface import VGGFace 但是，我得到以下错误： ModuleNotFoundError: No module named 'keras.engine.topology
浏览 717修改于2021-08-20得票数 0
现在，我正在做一个使用Kafka Streams来处理消息的项目。我们的消息由两个标识符组成，一个是用户的标识符，第二个是用户所属的消息列表的标识符。我的问题在这一点上出现了。我想停止发送推送消息，而不是通过kafka的流api消费所有消息。我在谷歌上搜索了最新的流源偏移量的变化，但找不到合适的方法来完成它。
浏览 0提问于2017-12-15得票数 1
当使用DirectX 11和MSVS2019时，在使用枚举'D3D11_USAGE‘和’D3D_PRIMITIVE_TOPOLOGY‘时会收到以下警告：
我能做些什么来解决这些警告？
浏览 1提问于2020-06-01得票数 0
回答已采纳
15/09/01 08:53:58 WARN net.ScriptBasedMapping: Exception running /etc/hadoop/conf.cloudera.yarn/topology.py10.0.0.5
java.io.IOException: Cannot run program "/etc/hadoop/conf.cloudera.yarn/topology.py" (in directory
浏览 2提问于2015-09-01得票数 6
我正在尝试使用Kafka to Storm来模拟数据流。我使用KafkaSpout从一个主题中读取一条消息，该消息是由一个生产者发送的，该生产者读取这些Tweet并将它们发送到一个主题。我的问题是，在拓扑使用了该主题中的所有tweet send之后，它会继续读取该主题中的消息两次。如何阻止KafkaSpout读取两次？(复制因子设置为1)
浏览 7修改于2019-06-19得票数 1
回答已采纳
当我尝试导入vggface时(在成功安装之后)，我得到消息： ModuleNotFoundError: No module named 'keras.engine.topology' 有没有人知道为什么会这样
浏览 1117提问于2021-08-23得票数 0
我在列表上使用.get_topology创建了一个系统树，但我不能将科学名称和排名添加到节点上。333367, 518636, 1262999, 657322, 550540, 44012, 748224, 518636, 1309411]t = ncbi.get_topology
浏览 13修改于2018-08-02得票数 0
/samoaException in thread "main" java.lang.NoClassDefFoundError: backtype/storm/topology/TopologyBuilder at org.apache.samoa.topology</e
浏览 5修改于2016-11-09得票数 1
我的拓扑结构部分依赖于使用第三方API，该API限制15分钟窗口中的某些调用。最坏的情况下，利率限制将下降，螺栓将需要睡15分钟。不幸的是，我似乎不能告诉风暴在15分钟的任务上“睡觉”，但我希望我错了。
浏览 3提问于2013-08-30得票数 4
回答已采纳
我在这里找到声明：，但无法从yaml ()中找到它的默认值。我试图在我的设置中调优这个参数，但是需要弄清楚什么是“推荐的”值。
浏览 3提问于2021-06-23得票数 0
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号