我们现场有这种适用场景,几万的终端,想直接把日志发送至kafka,然后再统一处理
终端设备?那是要走外网的吧。
内网终端
理论上你的瓶颈不会在生产者上。客户端方面没什么可调整的。
我测试过1万个线程同时往一个topic发消息,会出现发送失败情况,5000个线程能正常发送。我想问的就是kafka服务端这边怎么调整可以支持更多的线程并发。
我尝试过将 num.network.threads、socket.receive.buffer.bytes、socket.request.max.bytes、socket.send.buffer.bytes这些参数调大,但都没什么用
我是单机上启的1万个线程。如果每个连接都是长连接,服务端这边应该会受到socket端口个数限制吧
真实场景不就是这样么。跟服务器设置的openfile,kakfa的内存数等有关。
找不到想要的答案?提一个您自己的问题。
0 声望
这家伙太懒,什么都没留下
终端设备?那是要走外网的吧。
内网终端
理论上你的瓶颈不会在生产者上。客户端方面没什么可调整的。
我测试过1万个线程同时往一个topic发消息,会出现发送失败情况,5000个线程能正常发送。我想问的就是kafka服务端这边怎么调整可以支持更多的线程并发。
我尝试过将 num.network.threads、socket.receive.buffer.bytes、socket.request.max.bytes、socket.send.buffer.bytes
这些参数调大,但都没什么用
我是单机上启的1万个线程。
如果每个连接都是长连接,服务端这边应该会受到socket端口个数限制吧
真实场景不就是这样么。跟服务器设置的openfile,kakfa的内存数等有关。
你的答案