apache-kafka - Apache Storm が Kafka-topic に連続番号を書き込む

Question

カフカとストームでいくつかのパフォーマンステストを行いたいです。私の WordCount テストでは、連続番号が「出力」トピックに到着しています。

uLK 1
1352 
GaE 1
1353
IGF 1
1354 
DtJ 2
1355 
MVy 1
...

次のようになります。

uLK 1
GaE 1
IGF 1
DtJ 2 
MVy 1
...

私の嵐のトポロジは次のようになります。

builder.setSpout("kafkaSpoutPerfTest", kafkaSpout, 1);

builder.setBolt("split", new SplitSentence(), paralellismHint).shuffleGrouping("kafkaSpoutPerfTest");
builder.setBolt("count", new WordCount(), paralellismHint).fieldsGrouping("split", new Fields("message"));

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("acks", "0");
props.put("key.serializer","org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer","org.apache.kafka.common.serialization.StringSerializer");

KafkaBolt kafkaBolt = new KafkaBolt()
                .withProducerProperties(props)
                .withTopicSelector(new DefaultTopicSelector("output"));

builder.setBolt("kafkaBoltOutput", kafkaBolt, 1).shuffleGrouping("count");

私は何を間違っていますか？誰かが手がかりを持っていますか？ありがとう！