Pracuję z Storm i jest w porządku dla wielu przypadków użycia. Ostatnio rzuciłem okiem na Trident, która jest abstrakcją burzy na wysokim poziomie. Obsługuje on przetwarzanie dokładnie-raz i ułatwia s
Czytałem o Storm i bawiłem się z przykładami z burzy-rozrusznika. Myślę, że dostałem tę koncepcję i ma ona bardzo dobre zastosowanie w wielu przypadkach. Mam projekt testowy, który chcę zrobić, aby do
Jestem nowy dla Storm i staram się dowiedzieć, jak napisać test śrubowy, który testuje metodę execute(Tuple tuple) w podklasie BaseRichBolt. Problem jest taki, że wygląda na to, że Tuple jest niezmien
Próbuję ponownie zrównoważyć moją topologię Storm, która używa KafkaSpout. Mój kod to: TopologyBuilder builder = new TopologyBuilder();
Properties kafkaProps = new Properties();
kafkaProps.p