17
17
import org .jetbrains .annotations .NotNull ;
18
18
import org .junit .jupiter .api .Test ;
19
19
import org .junit .jupiter .api .extension .RegisterExtension ;
20
- import org .slf4j .LoggerFactory ;
21
20
import org .testcontainers .containers .GenericContainer ;
22
21
import org .testcontainers .containers .KafkaContainer ;
23
22
import org .testcontainers .containers .Network ;
24
- import org .testcontainers .containers .output .Slf4jLogConsumer ;
25
23
import org .testcontainers .containers .wait .strategy .HttpWaitStrategy ;
26
24
import org .testcontainers .containers .wait .strategy .Wait ;
27
25
import org .testcontainers .junit .jupiter .Container ;
@@ -57,7 +55,7 @@ public class AvroSchemaRegistryIT {
57
55
private final GenericContainer <?> questDBContainer = new GenericContainer <>("questdb/questdb:7.4.0" )
58
56
.withNetwork (network )
59
57
.withExposedPorts (QuestDBUtils .QUESTDB_HTTP_PORT )
60
- .withLogConsumer (new Slf4jLogConsumer (LoggerFactory .getLogger ("questdb" )))
58
+ // .withLogConsumer(new Slf4jLogConsumer(LoggerFactory.getLogger("questdb")))
61
59
.withEnv ("QDB_CAIRO_COMMIT_LAG" , "100" )
62
60
.withEnv ("JAVA_OPTS" , "-Djava.locale.providers=JRE,SPI" );
63
61
@@ -80,7 +78,7 @@ public class AvroSchemaRegistryIT {
80
78
.withExposedPorts (8083 )
81
79
.withCopyFileToContainer (MountableFile .forHostPath (connectorJarResolver .getJarPath ()), "/usr/share/java/kafka/questdb-connector.jar" )
82
80
.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")))
84
82
.dependsOn (kafkaContainer , questDBContainer )
85
83
.waitingFor (new HttpWaitStrategy ()
86
84
.forPath ("/connectors" )
0 commit comments