我设置了一个使用KubeMQ的集成测试，有时，当其中一个测试无法消化其测试套件中发送的所有消息时，这些消息可能会进入下一个测试并使其失败。
我想知道是否有办法强制KubeMQ丢弃所有存储的消息而不删除KubeMQ连接。应用程序在Go语言中，如果你有任何github.com/kubemq-io/kubemq-go特定的解决方案，那就更好了（我在包中找不到任何有用的东西）。