如何手动更新Kafka中某个Topic的偏移量

如题所述

第1个回答  2016-09-30
  分区实际上是调优Kafka并行度的最小单元。  对于producer而言,它实际上是用多个线程并发地向不同分区所在的broker发起Socket连接同时给这些分区发送消息; 而consumer呢,同一个消费组内的所有consumer线程都被指定topic的某一个分区进行消费(具。
相似回答