1717import org .jetbrains .annotations .NotNull ;
1818import org .junit .jupiter .api .Test ;
1919import org .junit .jupiter .api .extension .RegisterExtension ;
20- import org .slf4j .LoggerFactory ;
2120import org .testcontainers .containers .GenericContainer ;
2221import org .testcontainers .containers .KafkaContainer ;
2322import org .testcontainers .containers .Network ;
24- import org .testcontainers .containers .output .Slf4jLogConsumer ;
2523import org .testcontainers .containers .wait .strategy .HttpWaitStrategy ;
2624import org .testcontainers .containers .wait .strategy .Wait ;
2725import org .testcontainers .junit .jupiter .Container ;
@@ -57,7 +55,7 @@ public class AvroSchemaRegistryIT {
5755 private final GenericContainer <?> questDBContainer = new GenericContainer <>("questdb/questdb:7.4.0" )
5856 .withNetwork (network )
5957 .withExposedPorts (QuestDBUtils .QUESTDB_HTTP_PORT )
60- .withLogConsumer (new Slf4jLogConsumer (LoggerFactory .getLogger ("questdb" )))
58+ // .withLogConsumer(new Slf4jLogConsumer(LoggerFactory.getLogger("questdb")))
6159 .withEnv ("QDB_CAIRO_COMMIT_LAG" , "100" )
6260 .withEnv ("JAVA_OPTS" , "-Djava.locale.providers=JRE,SPI" );
6361
@@ -80,7 +78,7 @@ public class AvroSchemaRegistryIT {
8078 .withExposedPorts (8083 )
8179 .withCopyFileToContainer (MountableFile .forHostPath (connectorJarResolver .getJarPath ()), "/usr/share/java/kafka/questdb-connector.jar" )
8280 .withCopyFileToContainer (MountableFile .forHostPath (questdbJarResolver .getJarPath ()), "/usr/share/java/kafka/questdb.jar" )
83- .withLogConsumer (new Slf4jLogConsumer (LoggerFactory .getLogger ("connect" )))
81+ // .withLogConsumer(new Slf4jLogConsumer(LoggerFactory.getLogger("connect")))
8482 .dependsOn (kafkaContainer , questDBContainer )
8583 .waitingFor (new HttpWaitStrategy ()
8684 .forPath ("/connectors" )
0 commit comments