(kafka) branch trunk updated: KAFKA-13819: Add application.server to Streams assignor logs when set (#21605)

[mjsax]

This is an automated email from the ASF dual-hosted git repository.

mjsax pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 735218837c0 KAFKA-13819: Add application.server to Streams assignor 
logs when set (#21605)
735218837c0 is described below

commit 735218837c09b68925685b27ba3027685a1dc771
Author: Kartikay Dubey <90677227+dubeykarti...@users.noreply.github.com>
AuthorDate: Tue Apr 7 03:33:10 2026 +0530

    KAFKA-13819: Add application.server to Streams assignor logs when set 
(#21605)
    
    Add application.server to Kafka Streams assignor logs.
    
    Reviewers: Matthias J. Sax <matth...@confluent.io>
---
 .../processor/internals/assignment/AssignorConfiguration.java    | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git 
a/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignorConfiguration.java
 
b/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignorConfiguration.java
index dbf237df152..e13db1a4892 100644
--- 
a/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignorConfiguration.java
+++ 
b/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignorConfiguration.java
@@ -53,8 +53,15 @@ public final class AssignorConfiguration {
         streamsConfig = new ClientUtils.QuietStreamsConfig(configs);
         internalConfigs = configs;
 
+        final String appServerPrefix;
+        final String applicationServerEndpoint = 
streamsConfig.getString(StreamsConfig.APPLICATION_SERVER_CONFIG);
+        if (applicationServerEndpoint != null && 
!applicationServerEndpoint.isEmpty()) {
+            appServerPrefix = String.format("app-server [%s] ", 
applicationServerEndpoint);
+        } else {
+            appServerPrefix = "";
+        }
         // Setting the logger with the passed in client thread name
-        logPrefix = String.format("stream-thread [%s] ", 
streamsConfig.getString(CommonClientConfigs.CLIENT_ID_CONFIG));
+        logPrefix = String.format("stream-thread [%s] %s", 
streamsConfig.getString(CommonClientConfigs.CLIENT_ID_CONFIG), appServerPrefix);
         final LogContext logContext = new LogContext(logPrefix);
         log = logContext.logger(getClass());