Make capabilities configurable (#721)

Anastasiia Smirnova · web-flow · commit 32e9878b502f · 2021-09-02T17:16:58.000+03:00
fixes #495
diff --git a/README.adoc b/README.adoc
@@ -147,6 +147,7 @@ NOTE: embedded.kafka.enabled=false will cause DockerNotPresentException if you d
 |===
 
 === Other specific container related properties
+[cols="a,a,a"]
 |===
 |Setting name | Default value |Description
 
@@ -203,6 +204,12 @@ embedded.postgresql.mountVolumes:
   containerPath: "/var/lib/postgresql/data"
   mode: READ_WRITE
 ----
+
+|embedded.{module-name}.capabilities
+| empty list. `NET_ADMIN` is set for Aerospike, Couchbase, Elasticsearch, Kafka, Mariadb, Memsql, Minio, Mongodb, Mysql, Neo4j, Redis containers. NOTE: `NET_ADMIN` is needed for the `NetworkTestOperations` to work.
+|The Linux capabilities that should be enabled. You can disable all capabilities by providing empty value for this property.
+See: https://man7.org/linux/man-pages/man7/capabilities.7.html.
+Available values can be taken from `com.github.dockerjava.api.model.Capability` class.
 |===
 
 
diff --git a/embedded-aerospike/src/main/java/com/playtika/test/aerospike/AerospikeProperties.java b/embedded-aerospike/src/main/java/com/playtika/test/aerospike/AerospikeProperties.java
@@ -23,11 +23,14 @@
  */
 package com.playtika.test.aerospike;
 
+import com.github.dockerjava.api.model.Capability;
 import com.playtika.test.common.properties.CommonContainerProperties;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 
+import java.util.Arrays;
+
 @Data
 @EqualsAndHashCode(callSuper = true)
 @ConfigurationProperties("embedded.aerospike")
@@ -41,4 +44,8 @@ public class AerospikeProperties extends CommonContainerProperties {
     String host = "localhost";
     int port = 3000;
     String featureKey;
+
+    public AerospikeProperties() {
+        this.setCapabilities(Arrays.asList(Capability.NET_ADMIN));
+    }
 }
diff --git a/embedded-aerospike/src/main/java/com/playtika/test/aerospike/EmbeddedAerospikeBootstrapConfiguration.java b/embedded-aerospike/src/main/java/com/playtika/test/aerospike/EmbeddedAerospikeBootstrapConfiguration.java
@@ -81,7 +81,6 @@ public GenericContainer aerospike(AerospikeWaitStrategy aerospikeWaitStrategy,
                         .withEnv("SERVICE_PORT", String.valueOf(properties.port))
                         .withEnv("MEM_GB", String.valueOf(1))
                         .withEnv("STORAGE_GB", String.valueOf(1))
-                        .withCreateContainerCmdModifier(cmd -> cmd.getHostConfig().withCapAdd(Capability.NET_ADMIN))
                         .waitingFor(waitStrategy);
         String featureKey = properties.featureKey;
         if (featureKey != null) {
diff --git a/embedded-couchbase/src/main/java/com/playtika/test/couchbase/CouchbaseProperties.java b/embedded-couchbase/src/main/java/com/playtika/test/couchbase/CouchbaseProperties.java
@@ -23,12 +23,15 @@
  */
 package com.playtika.test.couchbase;
 
+import com.github.dockerjava.api.model.Capability;
 import com.playtika.test.common.properties.CommonContainerProperties;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 import org.testcontainers.couchbase.CouchbaseService;
 
+import java.util.Arrays;
+
 import static java.lang.String.format;
 
 /**
@@ -55,6 +58,10 @@ public class CouchbaseProperties extends CommonContainerProperties {
     String password = "password";
     String bucket = "test";
 
+    public CouchbaseProperties() {
+        this.setCapabilities(Arrays.asList(Capability.NET_ADMIN));
+    }
+
     public void setPassword(String password) {
         if (password.length() < 6) {
             throw new IllegalArgumentException("Couchbase requires password length >= 6 chars, password=" + password);
diff --git a/embedded-couchbase/src/main/java/com/playtika/test/couchbase/EmbeddedCouchbaseBootstrapConfiguration.java b/embedded-couchbase/src/main/java/com/playtika/test/couchbase/EmbeddedCouchbaseBootstrapConfiguration.java
@@ -62,8 +62,7 @@ public CouchbaseContainer couchbase(ConfigurableEnvironment environment,
         CouchbaseContainer couchbase = new CouchbaseContainer(properties.dockerImage)
                 .withBucket(bucketDefinition)
                 .withEnabledServices(properties.getServices())
-                .withCredentials(properties.getUser(), properties.getPassword())
-                .withCreateContainerCmdModifier(cmd -> cmd.getHostConfig().withCapAdd(Capability.NET_ADMIN));
+                .withCredentials(properties.getUser(), properties.getPassword());
 
         couchbase = (CouchbaseContainer) configureCommonsAndStart(couchbase, properties, log);
 
diff --git a/embedded-elasticsearch/src/main/java/com/playtika/test/elasticsearch/ElasticSearchContainerFactory.java b/embedded-elasticsearch/src/main/java/com/playtika/test/elasticsearch/ElasticSearchContainerFactory.java
@@ -42,7 +42,6 @@ static ElasticsearchContainer create(ElasticSearchProperties properties) {
                 .withEnv("cluster.name", properties.getClusterName())
                 .withEnv("discovery.type", "single-node")
                 .withEnv("ES_JAVA_OPTS", getJavaOpts(properties))
-                .withCreateContainerCmdModifier(cmd -> cmd.getHostConfig().withCapAdd(Capability.NET_ADMIN))
                 .waitingFor(getCompositeWaitStrategy(properties));
     }
 
diff --git a/embedded-elasticsearch/src/main/java/com/playtika/test/elasticsearch/ElasticSearchProperties.java b/embedded-elasticsearch/src/main/java/com/playtika/test/elasticsearch/ElasticSearchProperties.java
@@ -23,12 +23,14 @@
  */
 package com.playtika.test.elasticsearch;
 
+import com.github.dockerjava.api.model.Capability;
 import com.playtika.test.common.properties.CommonContainerProperties;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 
 import java.util.ArrayList;
+import java.util.Arrays;
 import java.util.List;
 
 @Data
@@ -45,4 +47,8 @@ public class ElasticSearchProperties extends CommonContainerProperties {
     int httpPort = 9200;
     int transportPort = 9300;
     int clusterRamMb = 256;
+
+    public ElasticSearchProperties() {
+        this.setCapabilities(Arrays.asList(Capability.NET_ADMIN));
+    }
 }
diff --git a/embedded-kafka/src/main/java/com/playtika/test/kafka/configuration/KafkaContainerConfiguration.java b/embedded-kafka/src/main/java/com/playtika/test/kafka/configuration/KafkaContainerConfiguration.java
@@ -113,7 +113,6 @@ public String getBootstrapServers() {
         }
                 .withCreateContainerCmdModifier(cmd -> cmd.withUser(kafkaProperties.getDockerUser()))
                 .withCreateContainerCmdModifier(cmd -> cmd.withHostName(KAFKA_HOST_NAME))
-                .withCreateContainerCmdModifier(cmd -> cmd.getHostConfig().withCapAdd(Capability.NET_ADMIN))
                 .withEmbeddedZookeeper()
                 .withEnv("KAFKA_BROKER_ID", "-1")
                 //see: https://stackoverflow.com/questions/41868161/kafka-in-kubernetes-cluster-how-to-publish-consume-messages-from-outside-of-kub
diff --git a/embedded-kafka/src/main/java/com/playtika/test/kafka/configuration/SchemaRegistryContainerConfiguration.java b/embedded-kafka/src/main/java/com/playtika/test/kafka/configuration/SchemaRegistryContainerConfiguration.java
@@ -62,7 +62,6 @@ public GenericContainer schemaRegistry(
 
         GenericContainer schemaRegistry = new FixedHostPortGenericContainer<>(properties.getDockerImage())
                 .withCreateContainerCmdModifier(cmd -> cmd.withHostName(SCHEMA_REGISTRY_HOST_NAME))
-                .withCreateContainerCmdModifier(cmd -> cmd.getHostConfig().withCapAdd(Capability.NET_ADMIN))
                 .withEnv("SCHEMA_REGISTRY_KAFKASTORE_BOOTSTRAP_SERVERS", "PLAINTEXT://" + kafkaContainerBrokerList)
                 .withEnv("SCHEMA_REGISTRY_HOST_NAME", SCHEMA_REGISTRY_HOST_NAME)
                 .withEnv("SCHEMA_REGISTRY_LISTENERS", "http://0.0.0.0:" + properties.getPort())
diff --git a/embedded-kafka/src/main/java/com/playtika/test/kafka/properties/KafkaConfigurationProperties.java b/embedded-kafka/src/main/java/com/playtika/test/kafka/properties/KafkaConfigurationProperties.java
@@ -23,6 +23,7 @@
  */
 package com.playtika.test.kafka.properties;
 
+import com.github.dockerjava.api.model.Capability;
 import com.playtika.test.common.properties.CommonContainerProperties;
 import com.playtika.test.common.utils.ContainerUtils;
 import lombok.AllArgsConstructor;
@@ -34,6 +35,7 @@
 
 import javax.annotation.PostConstruct;
 import javax.validation.constraints.AssertTrue;
+import java.util.Arrays;
 import java.util.Collection;
 import java.util.Collections;
 
@@ -81,6 +83,10 @@ public class KafkaConfigurationProperties extends CommonContainerProperties {
 
     protected FileSystemBind fileSystemBind = new FileSystemBind();
 
+    public KafkaConfigurationProperties() {
+        this.setCapabilities(Arrays.asList(Capability.NET_ADMIN));
+    }
+
     /**
      * Kafka container port will be assigned automatically if free port is available.
      * Override this only if you are sure that specified port is free.
diff --git a/embedded-kafka/src/main/java/com/playtika/test/kafka/properties/SchemaRegistryConfigurationProperties.java b/embedded-kafka/src/main/java/com/playtika/test/kafka/properties/SchemaRegistryConfigurationProperties.java
@@ -23,11 +23,14 @@
  */
 package com.playtika.test.kafka.properties;
 
+import com.github.dockerjava.api.model.Capability;
 import com.playtika.test.common.properties.CommonContainerProperties;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 
+import java.util.Arrays;
+
 import static com.playtika.test.kafka.properties.SchemaRegistryConfigurationProperties.Authentication.BASIC;
 import static com.playtika.test.kafka.properties.SchemaRegistryConfigurationProperties.Authentication.NONE;
 import static com.playtika.test.kafka.properties.SchemaRegistryConfigurationProperties.AvroCompatibilityLevel.BACKWARD;
@@ -50,6 +53,10 @@ public class SchemaRegistryConfigurationProperties extends CommonContainerProper
     private AvroCompatibilityLevel avroCompatibilityLevel = BACKWARD;
     private Authentication authentication = NONE;
 
+    public SchemaRegistryConfigurationProperties() {
+        this.setCapabilities(Arrays.asList(Capability.NET_ADMIN));
+    }
+
     public boolean isBasicAuthenticationEnabled() {
         return authentication == BASIC;
     }
diff --git a/embedded-mariadb/src/main/java/com/playtika/test/mariadb/EmbeddedMariaDBBootstrapConfiguration.java b/embedded-mariadb/src/main/java/com/playtika/test/mariadb/EmbeddedMariaDBBootstrapConfiguration.java
@@ -64,7 +64,6 @@ public MariaDBContainer mariadb(ConfigurableEnvironment environment,
                                 "--collation-server=" + properties.getCollation(),
                                 "--max_allowed_packet=" + properties.getMaxAllowedPacket())
                         .withExposedPorts(properties.port)
-                        .withCreateContainerCmdModifier(cmd -> cmd.getHostConfig().withCapAdd(Capability.NET_ADMIN))
                         .withInitScript(properties.initScriptPath);
         mariadb = (MariaDBContainer) configureCommonsAndStart(mariadb, properties, log);
         registerMariadbEnvironment(mariadb, environment, properties);
diff --git a/embedded-mariadb/src/main/java/com/playtika/test/mariadb/MariaDBProperties.java b/embedded-mariadb/src/main/java/com/playtika/test/mariadb/MariaDBProperties.java
@@ -23,11 +23,14 @@
  */
 package com.playtika.test.mariadb;
 
+import com.github.dockerjava.api.model.Capability;
 import com.playtika.test.common.properties.CommonContainerProperties;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 
+import java.util.Arrays;
+
 
 @Data
 @EqualsAndHashCode(callSuper = true)
@@ -50,4 +53,8 @@ public class MariaDBProperties extends CommonContainerProperties {
      * The SQL file path to execute after the container starts to initialize the database.
      */
     String initScriptPath;
+
+    public MariaDBProperties() {
+        this.setCapabilities(Arrays.asList(Capability.NET_ADMIN));
+    }
 }
diff --git a/embedded-memsql/src/main/java/com/playtika/test/memsql/EmbeddedMemSqlBootstrapConfiguration.java b/embedded-memsql/src/main/java/com/playtika/test/memsql/EmbeddedMemSqlBootstrapConfiguration.java
@@ -70,7 +70,6 @@ public GenericContainer memsql(ConfigurableEnvironment environment,
                 .withEnv("IGNORE_MIN_REQUIREMENTS", "1")
                 .withExposedPorts(properties.port)
                 .withCopyFileToContainer(MountableFile.forClasspathResource("mem.sql"), "/schema.sql")
-                .withCreateContainerCmdModifier(cmd -> cmd.getHostConfig().withCapAdd(Capability.NET_ADMIN))
                 .waitingFor(memSqlStatusCheck);
         if (network != null) {
           memsql = memsql.withNetwork(network);
diff --git a/embedded-memsql/src/main/java/com/playtika/test/memsql/MemSqlProperties.java b/embedded-memsql/src/main/java/com/playtika/test/memsql/MemSqlProperties.java
@@ -23,11 +23,14 @@
  */
 package com.playtika.test.memsql;
 
+import com.github.dockerjava.api.model.Capability;
 import com.playtika.test.common.properties.CommonContainerProperties;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 
+import java.util.Arrays;
+
 @Data
 @EqualsAndHashCode(callSuper = true)
 @ConfigurationProperties("embedded.memsql")
@@ -40,4 +43,8 @@ public class MemSqlProperties extends CommonContainerProperties {
     String schema = "test_db";
     String host = "localhost";
     int port = 3306;
+
+    public MemSqlProperties() {
+        this.setCapabilities(Arrays.asList(Capability.NET_ADMIN));
+    }
 }
diff --git a/embedded-minio/src/main/java/com/playtika/test/minio/EmbeddedMinioBootstrapConfiguration.java b/embedded-minio/src/main/java/com/playtika/test/minio/EmbeddedMinioBootstrapConfiguration.java
@@ -77,7 +77,6 @@ public GenericContainer minio(MinioWaitStrategy minioWaitStrategy,
                         .withEnv("MINIO_WORM", properties.worm)
                         .withEnv("MINIO_BROWSER", properties.browser)
                         .withCommand("server", properties.directory)
-                        .withCreateContainerCmdModifier(cmd -> cmd.getHostConfig().withCapAdd(Capability.NET_ADMIN))
                         .waitingFor(minioWaitStrategy);
 
         minio = configureCommonsAndStart(minio, properties, log);
diff --git a/embedded-minio/src/main/java/com/playtika/test/minio/MinioProperties.java b/embedded-minio/src/main/java/com/playtika/test/minio/MinioProperties.java
@@ -24,11 +24,14 @@
 
 package com.playtika.test.minio;
 
+import com.github.dockerjava.api.model.Capability;
 import com.playtika.test.common.properties.CommonContainerProperties;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 
+import java.util.Arrays;
+
 @Data
 @EqualsAndHashCode(callSuper = true)
 @ConfigurationProperties("embedded.minio")
@@ -49,4 +52,8 @@ public class MinioProperties extends CommonContainerProperties {
 
     String host = "localhost";
     int port = 9000;
+
+    public MinioProperties() {
+        this.setCapabilities(Arrays.asList(Capability.NET_ADMIN));
+    }
 }
diff --git a/embedded-mongodb/src/main/java/com/playtika/test/mongodb/EmbeddedMongodbBootstrapConfiguration.java b/embedded-mongodb/src/main/java/com/playtika/test/mongodb/EmbeddedMongodbBootstrapConfiguration.java
@@ -64,7 +64,6 @@ public GenericContainer mongodb(
                         .withEnv("MONGO_INITDB_ROOT_PASSWORD", properties.getPassword())
                         .withEnv("MONGO_INITDB_DATABASE", properties.getDatabase())
                         .withExposedPorts(properties.getPort())
-                        .withCreateContainerCmdModifier(cmd -> cmd.getHostConfig().withCapAdd(Capability.NET_ADMIN))
                         .waitingFor(mongodbStatusCheck);
 
         mongodb = configureCommonsAndStart(mongodb, properties, log);
diff --git a/embedded-mongodb/src/main/java/com/playtika/test/mongodb/MongodbProperties.java b/embedded-mongodb/src/main/java/com/playtika/test/mongodb/MongodbProperties.java
@@ -1,10 +1,13 @@
 package com.playtika.test.mongodb;
 
+import com.github.dockerjava.api.model.Capability;
 import com.playtika.test.common.properties.CommonContainerProperties;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 
+import java.util.Arrays;
+
 @Data
 @EqualsAndHashCode(callSuper = true)
 @ConfigurationProperties("embedded.mongodb")
@@ -23,4 +26,7 @@ public class MongodbProperties extends CommonContainerProperties {
     private String password;
     private String database = "test";
 
+    public MongodbProperties() {
+        this.setCapabilities(Arrays.asList(Capability.NET_ADMIN));
+    }
 }
diff --git a/embedded-mysql/src/main/java/com/playtika/test/mysql/EmbeddedMySQLBootstrapConfiguration.java b/embedded-mysql/src/main/java/com/playtika/test/mysql/EmbeddedMySQLBootstrapConfiguration.java
@@ -63,7 +63,6 @@ public MySQLContainer mysql(ConfigurableEnvironment environment,
                                 "--character-set-server=" + properties.getEncoding(),
                                 "--collation-server=" + properties.getCollation())
                         .withExposedPorts(properties.port)
-                        .withCreateContainerCmdModifier(cmd -> cmd.getHostConfig().withCapAdd(Capability.NET_ADMIN))
                         .withInitScript(properties.initScriptPath);
         mysql = (MySQLContainer) configureCommonsAndStart(mysql, properties, log);
         registerMySQLEnvironment(mysql, environment, properties);
diff --git a/embedded-mysql/src/main/java/com/playtika/test/mysql/MySQLProperties.java b/embedded-mysql/src/main/java/com/playtika/test/mysql/MySQLProperties.java
@@ -23,11 +23,14 @@
  */
 package com.playtika.test.mysql;
 
+import com.github.dockerjava.api.model.Capability;
 import com.playtika.test.common.properties.CommonContainerProperties;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 
+import java.util.Arrays;
+
 @Data
 @EqualsAndHashCode(callSuper = true)
 @ConfigurationProperties("embedded.mysql")
@@ -48,4 +51,8 @@ public class MySQLProperties extends CommonContainerProperties {
      * The SQL file path to execute after the container starts to initialize the database.
      */
     String initScriptPath;
+
+    public MySQLProperties() {
+        this.setCapabilities(Arrays.asList(Capability.NET_ADMIN));
+    }
 }
diff --git a/embedded-neo4j/src/main/java/com/playtika/test/neo4j/EmbeddedNeo4jBootstrapConfiguration.java b/embedded-neo4j/src/main/java/com/playtika/test/neo4j/EmbeddedNeo4jBootstrapConfiguration.java
@@ -57,8 +57,7 @@ public Neo4jContainer neo4j(ConfigurableEnvironment environment,
         log.info("Starting neo4j server. Docker image: {}", properties.dockerImage);
 
         Neo4jContainer neo4j = new Neo4jContainer<>(DockerImageName.parse(properties.dockerImage).asCompatibleSubstituteFor("neo4j"))
-                .withAdminPassword(properties.password)
-                .withCreateContainerCmdModifier(cmd -> cmd.getHostConfig().withCapAdd(Capability.NET_ADMIN));
+                .withAdminPassword(properties.password);
         neo4j = (Neo4jContainer) configureCommonsAndStart(neo4j, properties, log);
         registerNeo4jEnvironment(neo4j, environment, properties);
         return neo4j;
diff --git a/embedded-neo4j/src/main/java/com/playtika/test/neo4j/Neo4jProperties.java b/embedded-neo4j/src/main/java/com/playtika/test/neo4j/Neo4jProperties.java
@@ -23,11 +23,14 @@
  */
 package com.playtika.test.neo4j;
 
+import com.github.dockerjava.api.model.Capability;
 import com.playtika.test.common.properties.CommonContainerProperties;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 
+import java.util.Arrays;
+
 @Data
 @EqualsAndHashCode(callSuper = true)
 @ConfigurationProperties("embedded.neo4j")
@@ -40,4 +43,8 @@ public class Neo4jProperties extends CommonContainerProperties {
     int httpsPort = 7473;
     int httpPort = 7474;
     int boltPort = 7687;
+
+    public Neo4jProperties() {
+        this.setCapabilities(Arrays.asList(Capability.NET_ADMIN));
+    }
 }
diff --git a/embedded-redis/src/main/java/com/playtika/test/redis/EmbeddedRedisBootstrapConfiguration.java b/embedded-redis/src/main/java/com/playtika/test/redis/EmbeddedRedisBootstrapConfiguration.java
@@ -91,14 +91,12 @@ public GenericContainer redis(ConfigurableEnvironment environment,
 
         // CLUSTER SLOTS command returns IP:port for each node, so ports outside and inside
         // container must be the same
-        Consumer<CreateContainerCmd> containerCmdModifier = cmd -> cmd.getHostConfig().withCapAdd(Capability.NET_ADMIN);
         GenericContainer redis =
                 new FixedHostPortGenericContainer(properties.getDockerImage())
                         .withFixedExposedPort(properties.getPort(), properties.getPort())
                         .withExposedPorts(properties.getPort())
                         .withEnv("REDIS_USER", properties.getUser())
                         .withEnv("REDIS_PASSWORD", properties.getPassword())
-                        .withCreateContainerCmdModifier(containerCmdModifier)
                         .withCopyFileToContainer(MountableFile.forHostPath(prepareRedisConf()), "/data/redis.conf")
                         .withCopyFileToContainer(MountableFile.forHostPath(prepareNodesConf()), "/data/nodes.conf")
                         .withCommand("redis-server", "/data/redis.conf")
diff --git a/embedded-redis/src/main/java/com/playtika/test/redis/RedisProperties.java b/embedded-redis/src/main/java/com/playtika/test/redis/RedisProperties.java
diff --git a/testcontainers-common/src/main/java/com/playtika/test/common/properties/CommonContainerProperties.java b/testcontainers-common/src/main/java/com/playtika/test/common/properties/CommonContainerProperties.java
diff --git a/testcontainers-common/src/main/java/com/playtika/test/common/utils/ContainerUtils.java b/testcontainers-common/src/main/java/com/playtika/test/common/utils/ContainerUtils.java

Original file line number	Diff line number	Diff line change
`@@ -42,7 +42,6 @@ static ElasticsearchContainer create(ElasticSearchProperties properties) {`
`42`	`42`	`.withEnv("cluster.name", properties.getClusterName())`
`43`	`43`	`.withEnv("discovery.type", "single-node")`
`44`	`44`	`.withEnv("ES_JAVA_OPTS", getJavaOpts(properties))`
`45`		`- .withCreateContainerCmdModifier(cmd -> cmd.getHostConfig().withCapAdd(Capability.NET_ADMIN))`
`46`	`45`	`.waitingFor(getCompositeWaitStrategy(properties));`
`47`	`46`	`}`
`48`	`47`
Original file line number	Diff line number	Diff line change
`@@ -113,7 +113,6 @@ public String getBootstrapServers() {`
`113`	`113`	`}`
`114`	`114`	`.withCreateContainerCmdModifier(cmd -> cmd.withUser(kafkaProperties.getDockerUser()))`
`115`	`115`	`.withCreateContainerCmdModifier(cmd -> cmd.withHostName(KAFKA_HOST_NAME))`
`116`		`- .withCreateContainerCmdModifier(cmd -> cmd.getHostConfig().withCapAdd(Capability.NET_ADMIN))`
`117`	`116`	`.withEmbeddedZookeeper()`
`118`	`117`	`.withEnv("KAFKA_BROKER_ID", "-1")`
`119`	`118`	`//see: https://stackoverflow.com/questions/41868161/kafka-in-kubernetes-cluster-how-to-publish-consume-messages-from-outside-of-kub`