我在我的框架中使用 Kafka 生产者-消费者模型。消费者端消费的记录随后被索引到elasticsearch上。这里我有一个用例，如果 ES 关闭，我将不得不暂停 kafka 消费者，直到 ES 启动，一旦启动，我需要恢复消费者并使用我上次离开的位置的记录。我认为@KafkaListener 无法实现这一点。谁能给我一个解决方案吗？我发现我需要为此编写自己的 KafkaListenerContainer，但我无法正确实现它。任何帮助将非常感激。
从几天开始，我正在尝试将主题动态传递给 Kafka 侦听器的方法，而不是通过来自 Java DSL 的键使用它们。周围的任何人以前都这样做过，或者可以说明实现这一目标的最佳方法是什么？
我的HTML:
<input type ="text" ng-model="contactid" >
我想将此框中输入的contactId值传递给在框abc()后面调用onclick提交按钮的函数.
我该怎么做呢？