卡夫卡喷口的字段分组

Question

字段分组可以在卡夫卡喷口发出的元组上完成吗？如果是的话，那么Storm如何知道卡夫卡记录中的字段？

Answer 1

Kafka Spout声明其输出字段与任何其他组件一样。我的解释是基于KafkaSpout的当前implementation。

在KafkaSpout.java类中，我们看到了调用KafkaConfig方案的getOutputFields（）方法的declareOutputFields方法。

@Override 
public void declareOutputFields(OutputFieldsDeclarer declarer) { 
    declarer.declare(_spoutConfig.scheme.getOutputFields()); 
} 

默认情况下，KafkaConfig使用RawMultiScheme实现这样此方法。

@Override 
    public Fields getOutputFields() { 
    return new Fields("bytes"); 
    } 

那么这是什么意思？如果你宣布螺栓从KafkaSpout与fieldGrouping你知道包含每一个元组等于现场读取元组“字节”是要由同一个任务来执行。如果你想发射任何领域，你应该实现你的需求的新计划。

Answer 2

Storm中的字段分组（一般来说）用于螺栓，不适用于喷口。这是通过InputDeclarer课程完成的。
当您致电setBolt()TopologyBuilder时，返回InputDeclarer。