A 'Kafka > Storm > Kafka' Topology gotcha
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…
View On WordPress









