improve kafka intake stability