我有课

public**abstract**class BaseClass<K, V> implements SomeService {

    private KafkaTemplate<K, V> kafkaTemplate;

    @Override
    public void init(Map<String, Object> params) {
        DefaultKafkaProducerFactory<K, V> defaultKafkaProducerFactory = new DefaultKafkaProducerFactory<>(params);
        kafkaTemplate = new KafkaTemplate<>(defaultKafkaProducerFactory);
    }

    public void send(Message message) { 
        ProducerRecord<K, V> record = new ProducerRecord<>("topic", "key", someObject);
        RecordMetadata recordMetadata = kafkaTemplate.send(record).get().getRecordMetadata();
    }
}

我的问题是如何测试这个类，我唯一想做的就是检查kafkatemplate.send是否至少发生1次。
我不想使用带有spring的嵌入式kafka（对于这个测试来说太难了）。如何初始化和监视kafkatemplate的方法，而不是真正调用这些方法？