[kafka] branch trunk updated: MINOR: Logging fix in StreamsPartitionAssignor (#14435)

[lucasbru]

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

lucasbru 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 b58864e4769 MINOR: Logging fix in StreamsPartitionAssignor (#14435)
b58864e4769 is described below

commit b58864e47697907d00b5dbda7b24c3a0e54b7272
Author: Lucas Brutschy <lbruts...@confluent.io>
AuthorDate: Mon Oct 2 12:30:49 2023 +0200

    MINOR: Logging fix in StreamsPartitionAssignor (#14435)
    
    Fix broken log message
    
    Reviewer: A. Sophie Blee-Goldman <ableegold...@apache.org>
---
 .../kafka/streams/processor/internals/StreamsPartitionAssignor.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
 
b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
index e232ef15df0..3f16838dfc2 100644
--- 
a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
+++ 
b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
@@ -640,7 +640,7 @@ public class StreamsPartitionAssignor implements 
ConsumerPartitionAssignor, Conf
         log.info("Assigning stateful tasks: {}\n"
                      + "and stateless tasks: {}",
                  statefulTasks,
-                 allTasks.stream().filter(t -> !statefulTasks.contains(t)));
+                 allTasks.stream().filter(t -> 
!statefulTasks.contains(t)).collect(Collectors.toSet()));
         log.debug("Assigning tasks and {} standby replicas to client nodes {}",
                   numStandbyReplicas(), clientStates);