o `j<@sGdddZdS)c@s,eZdZdZdZeddZeddZdS)FindHangingTransactionsz find-hangingz7Find transactions older than the broker timeout + 5 mincCs*|jdtdddd|jdtddd dS) Nz --broker-idappend broker_idsz4Query only these brokers (repeatable). Default: all.)typeactiondesthelpz--max-transaction-timeout-msi zBroker's max-transaction-timeout (ms). Transactions older than this + 5 min are flagged as hanging. Default: 900000 (Kafka default).)rdefaultr) add_argumentint)clsparserr g/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/cli/admin/transactions/find_hanging.py add_argumentss z%FindHangingTransactions.add_argumentscCs6|j|j|jd}|D] }dd|dD|d<q |S)N)rmax_transaction_timeout_mscSsg|] }|j|jdqS)topic partitionr).0tpr r r s z3FindHangingTransactions.command..topic_partitions)find_hanging_transactionsrr)r clientargsresultsrowr r rcommands zFindHangingTransactions.commandN)__name__ __module__ __qualname__COMMANDHELP classmethodrrr r r rrs  rN)rr r r rs