Storm-路由螺栓来从卡夫卡模式壶口

Question

Storm - Conditionally consuming stream from kafka spout?

我怎么分割螺栓中的数据的模式，当我尝试输出使用declareOutputFields它（）。

场模式=新的领域（？）

我如何获得的所有字段在此螺栓中的数据的模式，而不基本上重新分析所有数据并重新创建它？

Answer 1

您需要事先了解架构，即在处理第一个元组之前。在第一次调用​​之前，在部署期间调用方法declareOutputFields()。

Storm无法处理变量模式。如果您有具有未知结构的JSON数据，则可以声明new Fields("json")并将整个JSON对象放入单个字段中。