add expose port and fix style

rekby · rekby · commit 09cd0c5c8aaa · 2025-01-10T11:00:16.000+03:00
diff --git a/tests/common/src/main/java/tech/ydb/test/integration/docker/YdbDockerContainer.java b/tests/common/src/main/java/tech/ydb/test/integration/docker/YdbDockerContainer.java
@@ -46,6 +46,7 @@ public YdbDockerContainer(YdbEnvironment env, PortsGenerator portGenerator) {
     public void init() {
         addExposedPort(grpcPort);
         addExposedPort(grpcsPort);
+        addExposedPort(kafkaPort);
 
         withEnv("YDB_KAFKA_PROXY_PORT", String.valueOf(kafkaPort));
         if (!env.useDockerIsolation()) {
@@ -91,7 +92,7 @@ public EndpointRecord secureEndpoint() {
         return new EndpointRecord(getHost(), getMappedPort(grpcsPort));
     }
 
-    public String nonSecureKafkaEndpoint(){
+    public String nonSecureKafkaEndpoint() {
         return getHost() + ":" + getMappedPort(kafkaPort);
     }
 

Original file line number	Diff line number	Diff line change
`@@ -46,6 +46,7 @@ public YdbDockerContainer(YdbEnvironment env, PortsGenerator portGenerator) {`
`46`	`46`	`public void init() {`
`47`	`47`	`addExposedPort(grpcPort);`
`48`	`48`	`addExposedPort(grpcsPort);`
	`49`	`+ addExposedPort(kafkaPort);`
`49`	`50`
`50`	`51`	`withEnv("YDB_KAFKA_PROXY_PORT", String.valueOf(kafkaPort));`
`51`	`52`	`if (!env.useDockerIsolation()) {`
`@@ -91,7 +92,7 @@ public EndpointRecord secureEndpoint() {`
`91`	`92`	`return new EndpointRecord(getHost(), getMappedPort(grpcsPort));`
`92`	`93`	`}`
`93`	`94`
`94`		`- public String nonSecureKafkaEndpoint(){`
	`95`	`+ public String nonSecureKafkaEndpoint() {`
`95`	`96`	`return getHost() + ":" + getMappedPort(kafkaPort);`
`96`	`97`	`}`
`97`	`98`