标签:rod 缓冲区 生产 异步发送 数据 调用 有一个 生产者 线程
kafka的生产者producer由持有未提交给kafka服务的记录的缓冲区构成一个缓冲区池,于此同时会有一个后台I/O线程来负责将这些记录record转化为请求request,然后将其提交给集群。
如果发送完数据之后不对producer进行资源释放close,会导致资源被挤占。
producer的send方法是异步的,当调用send方法提交一条记录到缓冲区之后,立即被返回。这样就能够允许生产者进行高效组织以批处理来发送数据。
标签:rod 缓冲区 生产 异步发送 数据 调用 有一个 生产者 线程
原文地址:https://blog.51cto.com/phpme/2515424