1.问题项目中通过kafka来对接上游，在项目中写一个listener监听topTopic队列，for循环消费records，在for循环中处理成存储到es的对象，一次拉50条，使用自定义线程池esThreadPool异步推送到es中，但是每次停机就会丢数据，例：kafka消费了1000条，但是往es中存储比较慢，优雅停机的时候，esThreadPool