22智能在线
新记
如何手动更新Kafka中某个Topic的偏移量
如题所述
举报该文章
其他看法
第1个回答 2016-09-30
分区实际上是调优Kafka并行度的最小单元。 对于producer而言,它实际上是用多个线程并发地向不同分区所在的broker发起Socket连接同时给这些分区发送消息; 而consumer呢,同一个消费组内的所有consumer线程都被指定topic的某一个分区进行消费(具。
相似回答
大家正在搜
相关问题
如何获取kafka某一topic中最新的offset
如何手动更新Kafka中某个Topic的偏移量
如何手动更新Kafka中某个Topic的偏移量
如何手动更新Kafka中某个Topic的偏移量
如何手动更新Kafka中某个Topic的偏移量
如何手动更新Kafka中某个Topic的偏移量
如何手动更新Kafka中某个Topic的偏移量
如何获取kafka某topic的Logsize