_producerListeners 应该调整下结构
Opened this issue · 1 comments
xinzhuxiansheng commented
private ConcurrentHashMap<String, Runnable> _producerListeners ,
假设,现在用户使用sdk 并且利用多线程,创建producer ,那么对于_producerListeners,就会出现,覆盖 ,可以利用 ConcurrentHashMap<String, List> 定义 _producerListeners
koqizhao commented
是的,这是考虑步骤的地方,会进行调整改进。