1
case class PartitionOffsetRequestInfo(time: Long, maxNumOffsets: Int)
任何人都知道macNumOffsets的手段,TYPartitionOffsetRequestInfo maxNumOffsets是什麼意思?
case class PartitionOffsetRequestInfo(time: Long, maxNumOffsets: Int)
任何人都知道macNumOffsets的手段,TYPartitionOffsetRequestInfo maxNumOffsets是什麼意思?
設置maxNumOffset到任何比1大給我們定時間之前多個消息抵消
參見:http://cfchou.github.io/blog/2015/04/23/a-closer-look-at-kafka-offsetrequest/
了它和ty :) –