以下是我的方法和测试方法：

@BeforeMethod
private void preTestSetup() throws Exception {
yfc = YFCLogCategory.instance(SamsCashActivation.class);
    yfc.setLogAll(true);
    PowerMockito.mockStatic(YFSSystem.class);
    PowerMockito.mockStatic(EarnEventHubProducer.class);
    PowerMockito.mockStatic(Future.class);
    PowerMockito.mockStatic(KafkaProducer.class);
    earnEventHubProducer = PowerMockito.mock(EarnEventHubProducer.class);
    MockitoAnnotations.initMocks(earnEventHubProducer);
    Mockito.when(kafkaProducer.send(Matchers.any(ProducerRecord.class), 
    Matchers.any())).thenReturn(future);
}
@Test
public void testPublishMethodEnabled() throws Exception {
    earnEventHubProducer.publish("payload", "OrderNo");
    Mockito.verify(kafkaProducer, Mockito.times(1)).send(Matchers.any(ProducerRecord.class), Matchers.any());
    Mockito.doNothing().when(kafkaProducer).close();
    earnEventHubProducer.cleanup();
    Mockito.verify(kafkaProducer, Mockito.times(1)).close();
}

当我运行这个命令时，它抛出：wanted但不调用：kafkaproducer.send（，）；实际上，这个模拟游戏没有任何互动。
我在earneventhubproducer中有一个发布方法。有人能帮我吗？