搜尋

首頁  >  問答  >  主體

java - Kafka的consumer如何根据offset来确定读取哪个patition呢?

天蓬老师天蓬老师2767 天前459

全部回覆(1)我來回復

  • PHPz

    PHPz2017-04-18 10:43:48

    內部儲存單元是map
    key是TopicPartition, 裡面記錄了topic和partition
    value是offset
    所以不存在只存在offset但是不知道partition的情況

    回覆
    0
  • 取消回覆