I have a spark streaming application configured to consume events from 2 Kafka topics. But when I run the application locally, the messages are consumed from either of these topics only and not both. If the first event is published to say topic2 and second message to topic1 then only the messages from topic2 are consumed.
But when I deployed the same code to an EMR cluster then the messages from both topics are being consumed.
Can someone please help what configuration could be missing when run locally? Thanks much in advance!