如何销毁kafka消息侦听器容器而不是停止它

How to destroy the kafka message listener container rather than stopping it

我正在尝试使用 KafkaListenerEndpointRegistry 在 运行 时间内动态添加/删除侦听器。此 class 提供了在 运行 时间内注册新侦听器的选项,但没有选项 destroy/unregister 已经 运行 的侦听器。我们有一个 stop API 来停止一个特定的容器,但我们必须销毁具有特定 id 的容器,并想用相同的 id 但不同的主题集重新注册它。 如果我们有可行的解决方案,请告诉我们。

注册表没有API完全删除容器。

不要使用端点注册表来创建这些容器,只需自己使用容器工厂(查看注册表中的代码),并跟踪它们;然后您可以根据需要 stop()destroy()