【问题标题】：@KafkaListener should pull new data only when a certain conditions is met, If condition fails pulling of data should stop until the condition is met@KafkaListener 仅在满足特定条件时才应拉取新数据，如果条件失败，则应停止拉取数据，直到满足条件
【发布时间】：2017-07-22 01:24:18
【问题描述】：
我正在处理的用例是从 KafkaListener 接收到的消息触发 Async 方法。我希望这个 Aysnc 方法完成，然后才从 kafka 队列接收新消息。关于此实施的任何想法或建议？ kakfka 能支持这样的场景吗？
例如
while(asyncMethod.idle()){
@KafkaListener(String data)
public void listen(){
process(message);
asyncMethod.execute();
}
}
【问题讨论】：
标签：
spring
apache-kafka
spring-kafka
【解决方案1】：
我对这个问题感到困惑，但听起来你想让这个同步与异步？
或者你可以实现一个锁，以确保它不会监听，除非锁为假，并在收到消息后将锁设置为真。
尽管您可能想要处理您的实现/架构，但不应该使用 Kafka 来维护秩序或阻止这种方式。