apache-kafka - バッチ化されたカフカ メッセージを嵐に保存するには、いくつかの例が必要です

Question

メッセージを取得するために通常のコンシューマーの例を試してみましたが、今はコンシューマーが嵐なので、バッチ化されたカフカメッセージを嵐に保存する必要がある例が必要です。

Answer 1

私は嵐カフカスパウトを使用しています。彼らのページでいくつかの例を見つけることができます。KafkaSpoutアプリケーションでクラスが必要でしたが、バッチもサポートしているようです:

Fields fields = new Fields("key", "message");
FixedBatchSpout spout = new FixedBatchSpout(fields, 4,
            new Values("storm", "1"),
            new Values("trident", "1"),
            new Values("needs", "1"),
            new Values("javadoc", "1")
);
spout.setCycle(true);
builder.setSpout("spout", spout, 5);

より具体的な例が必要な場合は、質問を絞り込んでください。