Kafka之生产者

生产者以什么样的策略把消息发到各个分区? 1.分区原因 (1)方便在集群中扩展,一个topic可以有多个partition组成,而每个partition可以通过调整以适应它所在的机器 (2)可以提高并发,因为可以以partition为单位读写 2.分区原则 我们需要将生产者发送的数据封装成一个ProducerRecord对象。 (1)指明partition的情况下,直接将指明的值作为partiti
相关文章
相关标签/搜索