Как написать testcase для встроенной кафки в приложении Springboot с использованием junit - PullRequest
Новая
       52

Как написать testcase для встроенной кафки в приложении Springboot с использованием junit

0 голосов
/ 04 марта 2020

я не знаю, как написать тестовый пример для встроенного kafka в springboot приложении с использованием junit mockito я ссылаюсь на некоторый код, и я использовал его, но KafkaEmbedded KafkaEmbedded is устарела 

 @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;
               }
             }
...