Set batch size for each Kafka pipeline

The source is putting data in one partition only. That could be the reason for slowness. But again this is linked to parsing of nested JSON mentioned in other post. Currently in code just looping through each array header and details for insert.