kafka引入了新的高级消费api和旧的 SimpleConsumer 现在已弃用。然而,文档缺少关于数据位置保证的信息。对于simpleconsumer,很明显数据只从一个代理读取。新的api呢?e、 如果我有两个服务器,每个服务器上有一个代理和一个使用者,有没有办法强制本地数据读取?或者每个消费者都会从随机经纪人那里读到?
SimpleConsumer
目前还没有任何答案,快来回答吧!
暂无答案!
目前还没有任何答案,快来回答吧!