Невозможно найти Необходимый тип: BiConsumer ⇐ JAVA

[Anonymous]

Я хочу перенести этот код Java в Spring Boot 3:

Код: Выделить всё

import java.util.function.BiConsumer;

public void send(String topic, K key, V message, BiConsumer callback) {
CompletableFuture future = kafkaTemplate.send(topic, key, message);
if (Objects.nonNull(callback)) {
future.whenComplete(callback);
}
}
......

// call kafka method
kafkaProducer().send("topic", "key",
"messge", listenableFutureCallback("12345"));

......

private ListenableFutureCallback listenableFutureCallback(String userId) {
return new ListenableFutureCallback() {
@Override
public void onFailure(Throwable ex) {
.......
}

@Override
public void onSuccess(Object result) {
........
}
};
}

Я получаю сообщение об ошибке в этой строке: ListenableFutureCallback("12345")

Код: Выделить всё

Required type: BiConsumer 
Provided: ListenableFutureCallback

Знаете ли вы, как мне перенести/заменить ListenableFutureCallback, чтобы вернуть BiConsumer из Java-метода ListenableFutureCallback?

Подробнее здесь: https://stackoverflow.com/questions/783 ... biconsumer