improve kafka intake stability
Merge pull request #332 from liquidm/improve-kafka

improve kafka intake stability