ran

# Transaction Tasks ### Kafka 2.8.0 and previous version transaction support: - [x] Transaction log https://github.com/streamnative/kop/pull/424, #716 - [ ] #915 - [x] Transaction timeout (#823) - [x] #896 -...

# Motivation KoP transaction log and recovery.

Add metrics for AoP

3

### Motivation Currently, there are no metrics for AoP, it's hard to monitor AoP status. This PR will add metrics for AoP. ### Modifications Add below metrics for AoP. MetricsLabel...

### Motivation Currently, the async method `consumer.handleFlow(DEFAULT_CONSUMER_PERMIT);` in basic consume command operation doesn't handle in an async way, this may cause NPE problem in the subsequent process. ### Modifications Start...

### Motivation Currently, the cursor of the exchange is a non-durable cursor, this will cause lost exchange data. ### Modifications Create durable cursors of the exchange topic in an async...

Support exchange properties

Support queue purge

Delete queue topic and cleanup all bound data.

Support queue bind properties

Support exclusive queue check. Support exclusive queue auto-delete when connection close.