我有一個使用 KubeMQ 的集成測試設置，有時，當其中一個無法消化在其測試套件中發送的所有消息時，消息可以進入下一個測試并使它們失敗。我想知道是否有辦法在不終止 KubeMQ 連接的情況下強制 KubeMQ 刪除所有存儲的消息。該應用程序在 Go 中，如果您有任何github.com/kubemq-io/kubemq-go特定的解決方案，它會更好（我無法在包中找到任何有用的東西）。