避免 HashMap 的线程安全问题，有多个解决方法，比如改用 HashTable 或者 Collections.synchronizedMap() 方法。 ConcurrentHashMap的优势在于兼顾性能和线程安全，一个线程进行写操作时，它会锁住一小部分，其他部分的读写不受影响，其他线程访问没上锁的地方不会被阻塞。

Flink 开发生产问题汇总，亲自解决的才是最宝贵的

为什么使用Kafka消息队列？ - 解耦 - 异步 - 削峰

升职加薪装逼技能