Can someone please help me in writing junit for completablefuture for kafkaproducer iam new to junit 5 kindly help
My producer code
CompletableFuture<Sendresult<str,str> future=kafkatemplate.send(topic,msg);
future.whencomplete((result,ex)->{
if(isempty(ex)
Sop(success)
else
Sop(error)
Sorry for bad alignment. Kindly help for creating junit5 for this class