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

Reply via email to