Hi,

I'm looking at the documentation for using KafkaSpout/KafkaBolt.

https://github.com/apache/storm/tree/master/external/storm-kafka

How is ordering guaranteed while reading messages from Kafka using
KafkaSpout?
Does the parallelism_hint set when a KafkaSpout is added to a topology,
need to match the number of partitions in a topic?

Similarly while writing back to Kafka, I believe fieldsGrouping can be used
so that tuples that have same field value will go to the same task and can
be written to the same partition.
Would like to get suggestions on this. Thanks!

Thanks
Kanagha

Reply via email to