Update files

bakdata · Jun 25, 2024 · ec0798e · ec0798e
1 parent 95dead8
commit ec0798e
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/streams-bootstrap-core/src/main/java/com/bakdata/kafka/ImprovedStreamsConfig.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/ImprovedStreamsConfig.java
@@ -75,7 +75,7 @@ public Map<String, Object> getStreamsConfig() {
      * @return an {@code Optional} containing the {@link HostInfo} if the
      * {@link StreamsConfig#APPLICATION_SERVER_CONFIG} is set; otherwise, an empty {@code Optional}.
      */
-    public Optional<HostInfo> getHostInfo() {
+    public Optional<HostInfo> getApplicationServer() {
         final String applicationServerConfig = this.streamsConfig.getString(APPLICATION_SERVER_CONFIG);
         return applicationServerConfig.isEmpty() ? Optional.empty()
                 : Optional.of(createHostInfo(applicationServerConfig));

diff --git a/streams-bootstrap-core/src/test/java/com/bakdata/kafka/ImprovedStreamsConfigTest.java b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/ImprovedStreamsConfigTest.java
@@ -81,7 +81,7 @@ void shouldHaveHostInfoIfApplicationServiceIsConfigure() {
                 Map.of(StreamsConfig.APPLICATION_ID_CONFIG, "test-app",
                         StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, "broker1:9092",
                         StreamsConfig.APPLICATION_SERVER_CONFIG, "localhost:9090"));
-        assertThat(new ImprovedStreamsConfig(config).getHostInfo())
+        assertThat(new ImprovedStreamsConfig(config).getApplicationServer())
                 .hasValue(new HostInfo("localhost", 9090));
     }
 
@@ -90,7 +90,7 @@ void shouldReturnEmptyHostInfoIfApplicationServiceIsNotConfigure() {
         final StreamsConfig config = new StreamsConfig(
                 Map.of(StreamsConfig.APPLICATION_ID_CONFIG, "test-app",
                         StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092"));
-        assertThat(new ImprovedStreamsConfig(config).getHostInfo())
+        assertThat(new ImprovedStreamsConfig(config).getApplicationServer())
                 .isEmpty();
     }