Correcting key problem due to estimation time of the estimator Using poll for listening to 2 different kafka topics