Hi all, I am reading the docs of receiver-based Kafka consumer. The last parameters of KafkaUtils.createStream is per topic number of Kafka partitions to consume. My question is, does the number of partitions for topic in this parameter need to match the number of partitions in Kafka.
For example, I have two topics, topic1 with 3 partitions and topic2 with 4 partitions. If i specify 2 for topic1 and 3 for topic2 and feed them to the createStream function, will there be data loss? Or it will just be an inefficiency. Thanks! Bill