特牛网址导航

kafka工作流程_kafka发生流程_不良反应的博客-CSDN博客

网友收藏
一、生产者端1.将数据包装为ProducerRecord对象 Producer通过调用send(ProducerRecord)发送消息,ProducerRecord对象包含Topic等信息2.Interceptor 拦截器,通过API可以自定义拦截器,过滤掉不需要的信息3.序列化 由于kafka是集群工作模式,集群之间传递需要序列化(Serilizer)4.分区(partition) send()函数参数Topic、va..._kafka发生流程