![]() |
1
1
我不认为这样的东西是内置的你可能要做的是把你无法处理的记录写到某个地方(比如卡夫卡),直到你能处理它们当您可以处理它们时,您可以通过将无法处理的记录主题添加到Kafka输入主题来让Storm接收它们,或者启动仅从无法处理的记录数据源使用的拓扑的另一个副本。 |
![]() |
Ajeesh · Apache Storm(1.2.1)运输异常断管 7 年前 |
![]() |
Aniruddha · 在storm群集上提交拓扑时出错 7 年前 |
![]() |
kingluo · storm:bolt如何执行元组? 7 年前 |
![]() |
Saurabh · 在Apache Storm中使用与多个螺栓相同的类 7 年前 |
|
Keshore Durairaj · 实时流数据聚合 7 年前 |
![]() |
Ryanqy · 监管在风暴中意味着什么? 7 年前 |
![]() |
jdowdell · 流处理架构:未来事件影响过去结果 7 年前 |