After retrieving a kafka stream or kafka message how to get the corresponding partition number to which it belongs ? I am using kafka version 0.8.1. More specifically kafka.consumer.KafkaStream and kafka.message.MessageAndMetaData classes, does not provide API to retrieve partition number. Are there any other API's to get the partition number?
IF there are multiple partitions of a topic ,Do i need to declare from java code how many partitions the topic contains or i can leave it topic Kafkastream will take the partition information from kafka broker at runtime.?
