执行一个方法Kafka回调

Question

我有一个RestController，它调用KafkaSendMethod((将消息发送到Kafka MQ

@RestController
@RequestMapping("string-rest")
public class SimpleBookRestController {
@Autowire
private KafkaSendClass kafkaSendClass;

@GetMapping( produces = "application/json")
public void postMethod() {

ArrayList<String> gfg = new ArrayList<String>(); 
gfg.add("a"); 
gfg.add("b"); 
gfg.add("c");

kafkaSendClass.KafkaSendMethod(gfg);

}

这是向Kafka 发送消息的类

@Service
class KafkaSendClass
{

@Autowired
private KafkaTemplate<String, String> kafkaTemplate;

void KafkaSendMethod(List<Strings> strList)
{

for ( String str : strList )
(
ListenableFuture<SendResult<String,String>>   future = kafkaTemplate.send(str , str );
future.addCallback(new ListenableFutureCallback<SendResult<String, String>>() {

@Override
public void onSuccess(SendResult<String, String> result) {
syso("sent success");
m1(); //call only once for one call to KafkaSendMethod() ;
}

@Override
public void onFailure(Throwable ex) {
System.out.println(" sending failed");
}
});

)；所以我的问题是，如何在每次调用KafkaSendMethod(List-strList(时调用m1((。

Answer 1

查看是否可以使用CompletableFuture.allOf(...)。

将这些Future收集到一个列表中，并使用它们的completable()自适应。然后为该CompletableFuture调用List.toArray()。CompletableToListenableFutureAdapter添加您的最终回调。