First Batch:- I am trying to pull data from 100 flat file and loading up into an array and inserting them to kafka producer one by one as byte array.
Second Batch:- I am consuming from kafka consumer and then inserting them to NoSQL database.
I use Offsetnewset in the config file of shopify sarama golang package for Kafka.
I can receive and insert messages to kafka but while consuming I am getting only the first message. Since I gave Offset newest in the sarama config. how can I get all the data here.