[kafka] branch 3.5 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 3.5
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/3.5 by this push:
     new 8f7310eab6c MINOR: Logging fix in StreamsPartitionAssignor (#14435)
8f7310eab6c is described below

commit 8f7310eab6cb73da6d8ab4893354bf945be78ed0
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 2da8f1e47c2..eded403973e 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
@@ -633,7 +633,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);