Storm-路由螺栓來從卡夫卡模式壺口

Question

Storm - Conditionally consuming stream from kafka spout?

我怎麼分割螺栓中的數據的模式，當我嘗試輸出使用declareOutputFields它（）。

場模式=新的領域（？）

我如何獲得的所有字段在此螺栓中的數據的模式，而不基本上重新分析所有數據並重新創建它？

Answer 1

您需要事先了解架構，即在處理第一個元組之前。在第一次調用​​之前，在部署期間調用方法declareOutputFields()。

Storm無法處理變量模式。如果您有具有未知結構的JSON數據，則可以聲明new Fields("json")並將整個JSON對象放入單個字段中。