java - 如何使用junit在springboot应用程序中为嵌入式kafka编写测试用例

Question

我不知道如何使用junit mockito在springboot应用程序中为嵌入式kafka编写测试用例我参考了一些代码并且我使用了它但是KafkaEmbedded KafkaEmbedded 已被弃用

 @TestConfiguration
        @EmbeddedKafka(partitions = 1, controlledShutdown = false,
        brokerProperties = {"listeners=PLAINTEXT://localhost:3333", "port=3333"})
        public class KafkaTestConfig {
            @Autowired
             KafkaEmbedded kafkaEmbeded;
            @Autowired
            KafkaListenerEndpointRegistry kafkaListenerEndpointRegistry;
            @Before
            public void setUp() throws Exception {
              for (MessageListenerContainer messageListenerContainer : kafkaListenerEndpointRegistry.getListenerContainers()) {
                ContainerTestUtils.waitForAssignment(messageListenerContainer, 
                kafkaEmbeded.getPartitionsPerTopic());
              }
            }
            @Bean
            public ProducerFactory<String, Object> producerFactory() {
                return new DefaultKafkaProducerFactory<>(KafkaTestUtils.producerProps(kafkaEmbeded));
            }
            @Bean
            public KafkaTemplate<String, Object> kafkaTemplate() {
                KafkaTemplate<String, Object> kafkaTemplate = new KafkaTemplate<>(producerFactory());
                return kafkaTemplate;
               }
             }