ストロム - 信頼性の高いスパウトとして信頼性の高い<br> を噴出ストロムを設定する方法

Question

が
を設定するための任意のプロパティがありますがカフカは、デフォルトでは信頼性のある方法kafkaSpout

でreliablityを変更する

Answer 1

デフォルト
によってkafkaSpoutが信頼性はあります。ここではカフカのトピックからメッセージを読み取るための責任があるPartitionManagerクラスからのコードは次のとおりです。

collector.emit(tup, new KafkaMessageId(_partition, toEmit.offset()));

あなたが発するメソッドの2番目のパラメータがKafkaMessageIdで見ることができるように。同様の方法でスパウトにメッセージIDを渡すことができます。メッセージIDは通常の整数にすることができます。