I am facing issue while fetching 2 million records from kafka topic through a consumer.
My requirement is to fetch the record and store those records into a Map and return that Map to other methods so they can process and write the final output to a file.
Adding the run method here –
public Map<String, SaleRecord> run() throws NullPointerException {
kafkaConfigurations();