#kafkaspout

A ‘Kafka > Storm > Kafka’ Topology gotcha

If you’re trying to make a Kafka <-> Storm topology work, and are going bonkers over your recipient topic not receiving any damn thing, here’s the secret:

The defaultorg.apache.storm.kafka.bolt.KafkaBolt implementation expects only a single key field from the upstream (Bolt/Spout)

If you’re tieing your KafkaBoltto aKafkaSpout, you’ve got to use the internal name:str

However, if you have an…