|
|
|
@ -36,7 +36,6 @@ import java.util.concurrent.ExecutionException;
@@ -36,7 +36,6 @@ import java.util.concurrent.ExecutionException;
|
|
|
|
|
import java.util.concurrent.Future; |
|
|
|
|
import java.util.concurrent.TimeoutException; |
|
|
|
|
|
|
|
|
|
import static org.junit.jupiter.api.Assertions.assertDoesNotThrow; |
|
|
|
|
import static org.junit.jupiter.api.Assertions.assertEquals; |
|
|
|
|
import static org.junit.jupiter.api.Assertions.assertThrows; |
|
|
|
|
|
|
|
|
@ -140,7 +139,7 @@ public class KafkaLog4jAppenderTest {
@@ -140,7 +139,7 @@ public class KafkaLog4jAppenderTest {
|
|
|
|
|
MockKafkaLog4jAppender mockKafkaLog4jAppender = getMockKafkaLog4jAppender(); |
|
|
|
|
replaceProducerWithMocked(mockKafkaLog4jAppender, true); |
|
|
|
|
|
|
|
|
|
assertDoesNotThrow(() -> logger.error(getMessage(0))); |
|
|
|
|
logger.error(getMessage(0)); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
@Test |
|
|
|
@ -148,7 +147,7 @@ public class KafkaLog4jAppenderTest {
@@ -148,7 +147,7 @@ public class KafkaLog4jAppenderTest {
|
|
|
|
|
Properties props = getLog4jConfigWithRealProducer(true); |
|
|
|
|
PropertyConfigurator.configure(props); |
|
|
|
|
|
|
|
|
|
assertDoesNotThrow(() -> logger.error(getMessage(0))); |
|
|
|
|
logger.error(getMessage(0)); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
@Test |
|
|
|
|