[kafka] branch trunk updated: MINOR: Fix KafkaStreams#streamThreadLeaveConsumerGroup logging (#14526)

[ableegoldman]

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

ableegoldman 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 7d1847c4c34 MINOR: Fix KafkaStreams#streamThreadLeaveConsumerGroup 
logging (#14526)
7d1847c4c34 is described below

commit 7d1847c4c34abc5dc5657ab8524a5f9d99077e41
Author: Levani Kokhreidze <levani.kokhrei...@transferwise.com>
AuthorDate: Thu Oct 12 02:14:25 2023 +0300

    MINOR: Fix KafkaStreams#streamThreadLeaveConsumerGroup logging (#14526)
    
    Fixes logging for KafkaStreams#streamThreadLeaveConsumerGroup.
    
    In order not to lose the trace of the whole exception, passing Exception e 
as a second argument, while message is pre-formatted and passed as string as a 
first argument. With this, we won't loose the stack trace of the exception.
    
    Reviewers: Anna Sophie Blee-Goldman <sop...@responsive.dev>
---
 streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java 
b/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
index 586e0c5f30e..da998d5d983 100644
--- a/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
+++ b/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
@@ -1548,9 +1548,9 @@ public class KafkaStreams implements AutoCloseable {
                     
removeMembersFromConsumerGroupResult.memberResult(memberToRemove)
                         .get(remainingTimeMs, TimeUnit.MILLISECONDS);
                 } catch (final Exception e) {
-                    log.error("Could not remove static member {} from consumer 
group {} due to a: {}",
-                        groupInstanceId.get(),
-                        
applicationConfigs.getString(StreamsConfig.APPLICATION_ID_CONFIG), e);
+                    final String msg = String.format("Could not remove static 
member %s from consumer group %s.",
+                                                     groupInstanceId.get(), 
applicationConfigs.getString(StreamsConfig.APPLICATION_ID_CONFIG));
+                    log.error(msg, e);
                 }
             }
         };