...

kafka-transactions.sh --list  command will have a new option, --durationFilter  to return transactions running longer than this time duration, specified in milli seconds.

kafka-transactions.sh --describe  command will change the way it prints the value for transaction duration for completed transactions.

If TransactionLastUpdateTimeMs field is present in DescribeTransactionsResponse, transaction duration will be printed as the difference of TransactionLastUpdateTimeMs  and transactionStartTime. On the other hand, if this field is not present, transaction duration value cannot be determined correctly (for completed transactions) and we will print -1.

Proposed Changes

We propose to add a Duration filter to ListTransactionsOptions in order to list only the transactions older than a certain time duration.

...