@@ -0,0 +1,2072 @@
+package com.github.rozidan.springboot.levelog;%0A%0Aimport org.apache.kafka.clients.consumer.ConsumerConfig;%0Aimport org.junit.Test;%0Aimport org.junit.runner.RunWith;%0Aimport org.springframework.beans.factory.annotation.Autowired;%0Aimport org.springframework.boot.autoconfigure.EnableAutoConfiguration;%0Aimport org.springframework.context.annotation.Configuration;%0Aimport org.springframework.kafka.annotation.EnableKafka;%0Aimport org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory;%0Aimport org.springframework.kafka.config.KafkaListenerContainerFactory;%0Aimport org.springframework.kafka.core.DefaultKafkaConsumerFactory;%0Aimport org.springframework.kafka.listener.ConcurrentMessageListenerContainer;%0Aimport org.springframework.test.context.TestPropertySource;%0Aimport org.springframework.test.context.junit4.SpringRunner;%0A%0Aimport static org.assertj.core.api.Assertions.assertThat;%0A%0A@RunWith(SpringRunner.class)%0A@TestPropertySource(properties = %7B%0A        %22levelog.kafka.servers:localhost:19092%22,%0A        %22levelog.kafka.enabled=true%22%7D)%0Apublic class LevelogKafkaDefaultConsumerTest %7B%0A%0A    @Autowired(required = false)%0A    private KafkaListenerContainerFactory%3CConcurrentMessageListenerContainer%3CString, Message%3E%3E levelogKafkaContainer;%0A%0A    @Test%0A    public void setCustomServersWithTheDefaultConsumer() %7B%0A        assertThat(levelogKafkaContainer).isInstanceOf(ConcurrentKafkaListenerContainerFactory.class);%0A        ConcurrentKafkaListenerContainerFactory%3CString, Message%3E container = (ConcurrentKafkaListenerContainerFactory%3CString, Message%3E) levelogKafkaContainer;%0A%0A        assertThat(container.getConsumerFactory()).isInstanceOf(DefaultKafkaConsumerFactory.class);%0A        DefaultKafkaConsumerFactory%3CString, Message%3E Consumer = (DefaultKafkaConsumerFactory%3CString, Message%3E) container.getConsumerFactory();%0A%0A        assertThat(Consumer.getConfigurationProperties().get(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG)).isEqualTo(%22localhost:19092%22);%0A%0A    %7D%0A%0A    @Configuration%0A    @EnableAutoConfiguration%0A    @EnableKafka%0A    public static class Application %7B%0A%0A    %7D%0A%7D%0A

add unit test setCustomServersWithTheDefaultConsumer