小编Jut*_*uto的帖子

我正在设置一个风暴群来计算实时趋势和其他统计数据,但是我在将这个"恢复"功能引入到这个项目中时遇到了一些问题,允许上次读取的偏移量kafka-spout(源代码kafka-spout来自https: //github.com/apache/incubator-storm/tree/master/external/storm-kafka)值得记住.我kafka-spout以这种方式开始:

BrokerHosts zkHost = new ZkHosts("localhost:2181");
SpoutConfig kafkaConfig = new SpoutConfig(zkHost, "test", "", "test");
kafkaConfig.forceFromStart = false;
KafkaSpout kafkaSpout = new KafkaSpout(kafkaConfig);
TopologyBuilder builder = new TopologyBuilder();
builder.setSpout("test" + "spout", kafkaSpout, ESConfig.spoutParallelism);

默认设置应该这样做,但我认为在我的情况下它没有这样做,每次我启动我的项目时,PartitionManager尝试查找带有偏移量的文件,然后找不到任何内容:

2014-06-25 11:57:08 INFO  PartitionManager:73 - Read partition information from: /storm/partition_1  --> null
2014-06-25 11:57:08 INFO  PartitionManager:86 - No partition information found, using configuration to determine offset

然后它开始从最新的可能偏移读取.如果我的项目永远不会失败,那就没关系,但不完全是我想要的.

我还看了一下PartitionManager使用Zkstate类来编写偏移量的类,从这段代码片段:

PartitionManeger

public void commit() …

简单的问题,但我没有成功找到一个满意的答案.

当我有引导警报时:

<div id='alert' class='alert alert-error hide'>Alert.</div>

我希望使用jQuery的Javascript来控制文本,我只是看了解这个问题的解决方案,但它是否必须如此复杂？真？

特定

int x[10];
int y[10];
int n = 10;

版本1

int i = 0;
while (i < n)
  y[i] = x[i++];

版本2

for (int i = 0; i < n; i++)
  y[i] = x[i]

这两个版本总是相同吗？如果没有,他们什么时候不相同？