kafka笔记五 API

文章目录 dependencies Producer Consumer 自定义分区的Producer 生产者端自定义拦截器Interceptor Kafka 的 Producer 发送消息采用的是异步发送的方式。在消息发送的过程当中,涉及到了两个线程——main 线程和Sender 线程,以及一个线程共享变量——RecordAccumulator。web main 线程将消息发送给 RecordA
相关文章
相关标签/搜索