move main() in KafkaSpout to TestTopology.
find leader of partitions
find new leader of partitions when metadata is obsolete.
Merge remote-tracking branch 'origin/master'