阅读背景:

kafka-producer partitioner.class的使用

来源:互联网 

partitioner.class的说明

 

在API客户端中封装好的partition( )方法会为消息选择一个分区编号。为了保证消息负载均衡到每个分区,可以通过使用默认方式或者在API客户端中封装好的partitio




你的当前访问异常,请进行认证后继续阅读剩余内容。

分享到: