This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-connectors-kafka.git
The following commit(s) were added to refs/heads/main by this push:
new d29dc319 getContainerIpAddress is deprecated (#237)
d29dc319 is described below
commit d29dc319ce4eef75a9ad5f246719c010d3d441af
Author: PJ Fanning <[email protected]>
AuthorDate: Tue Oct 1 19:00:53 2024 +0100
getContainerIpAddress is deprecated (#237)
* getContainerIpAddress is deprecated
* javafmt
---
.../pekko/kafka/testkit/internal/PekkoConnectorsKafkaContainer.java | 5 ++---
.../apache/pekko/kafka/testkit/internal/SchemaRegistryContainer.java | 3 +--
2 files changed, 3 insertions(+), 5 deletions(-)
diff --git
a/testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/PekkoConnectorsKafkaContainer.java
b/testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/PekkoConnectorsKafkaContainer.java
index b062cc9f..3c074cf4 100644
---
a/testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/PekkoConnectorsKafkaContainer.java
+++
b/testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/PekkoConnectorsKafkaContainer.java
@@ -165,7 +165,7 @@ public class PekkoConnectorsKafkaContainer extends
GenericContainer<PekkoConnect
if (port == PORT_NOT_ASSIGNED) {
throw new IllegalStateException("You should start Kafka container
first");
}
- return String.format("PLAINTEXT://%s:%s", getContainerIpAddress(), port);
+ return String.format("PLAINTEXT://%s:%s", getHost(), port);
}
public String getJmxServiceUrl() {
@@ -173,8 +173,7 @@ public class PekkoConnectorsKafkaContainer extends
GenericContainer<PekkoConnect
throw new IllegalStateException("You should start Kafka container
first");
}
- return String.format(
- "service:jmx:rmi:///jndi/rmi://%s:%s/jmxrmi", getContainerIpAddress(),
jmxPort);
+ return String.format("service:jmx:rmi:///jndi/rmi://%s:%s/jmxrmi",
getHost(), jmxPort);
}
@Override
diff --git
a/testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/SchemaRegistryContainer.java
b/testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/SchemaRegistryContainer.java
index 3e9280d9..722bfd6b 100644
---
a/testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/SchemaRegistryContainer.java
+++
b/testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/SchemaRegistryContainer.java
@@ -48,7 +48,6 @@ public class SchemaRegistryContainer extends
GenericContainer<SchemaRegistryCont
}
public String getSchemaRegistryUrl() {
- return String.format(
- "http://%s:%s";, getContainerIpAddress(),
getMappedPort(SCHEMA_REGISTRY_PORT));
+ return String.format("http://%s:%s";, getHost(),
getMappedPort(SCHEMA_REGISTRY_PORT));
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
