Merge pull request #19736 from joyrex2001/main

Fix async i/o error and move startup script
quarkusio · Aug 27, 2021 · 6c3b462 · 6c3b462
2 parents 9cc17ee + ef19b7e
commit 6c3b462
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...eployment/src/main/java/io/quarkus/kafka/client/deployment/DevServicesKafkaProcessor.java b/...eployment/src/main/java/io/quarkus/kafka/client/deployment/DevServicesKafkaProcessor.java
@@ -325,7 +325,7 @@ private static final class RedPandaKafkaContainer extends GenericContainer<RedPa
 
         private String hostName = null;
 
-        private static final String STARTER_SCRIPT = "/redpanda.sh";
+        private static final String STARTER_SCRIPT = "/var/lib/redpanda/redpanda.sh";
 
         private RedPandaKafkaContainer(DockerImageName dockerImageName, int fixedExposedPort, String serviceName,
                 boolean useSharedNetwork) {
@@ -360,7 +360,7 @@ protected void containerIsStarting(InspectContainerResponse containerInfo, boole
 
             // Start and configure the advertised address
             String command = "#!/bin/bash\n";
-            command += "/usr/bin/rpk redpanda start --check=false --node-id 0 ";
+            command += "/usr/bin/rpk redpanda start --check=false --node-id 0 --smp 1 ";
             command += "--kafka-addr PLAINTEXT://0.0.0.0:29092,OUTSIDE://0.0.0.0:9092 ";
             command += String.format("--advertise-kafka-addr PLAINTEXT://%s:29092,OUTSIDE://%s:%d", getHostToUse(),
                     getHostToUse(), getPortToUse());