Hi PoAn chia_10 > The timestamp is set when pause() is called, cleared (reset to -1) when > resume() is called, and also reset to -1 on partition reassignment regardless > of prior pause status.
Is this the implementation details? Or the timestamp is a kind of public stuff? Chia_11 As Matthias mentioned in the jira, should we add a metric to trace the longest duration among all paused partition? Best, Chia-Ping On 2026/04/06 11:03:35 PoAn Yang wrote: > Hello everyone, > > I would like to start a discussion thread on KIP-1304. In this KIP, we plan > to add new consumer metrics about paused partitions. > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-1304%3A+Add+consumer+metric+about+paused+partitions > > Please take a look and feel free to share any thoughts. > > Thanks, > PoAn
