[kafka] branch trunk updated: MINOR: remove onChange call in stream assignor assign method (#13034)

[vvcephei]

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

vvcephei 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 ca15735fa7b MINOR: remove onChange call in stream assignor assign 
method (#13034)
ca15735fa7b is described below

commit ca15735fa7bc3e1d1287bee5edd5dd83a3dd03f0
Author: Hao Li <1127478+lihao...@users.noreply.github.com>
AuthorDate: Wed Dec 21 16:32:05 2022 -0800

    MINOR: remove onChange call in stream assignor assign method (#13034)
    
    Reviewers: John Roesler <vvcep...@apache.org>
---
 .../kafka/streams/processor/internals/StreamsPartitionAssignor.java      | 1 -
 1 file changed, 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 4b7d85a5d78..1875f57b649 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
@@ -422,7 +422,6 @@ public class StreamsPartitionAssignor implements 
ConsumerPartitionAssignor, Conf
             if (minReceivedMetadataVersion >= 2) {
                 populatePartitionsByHostMaps(partitionsByHost, 
standbyPartitionsByHost, partitionsForTask, clientMetadataMap);
             }
-            streamsMetadataState.onChange(partitionsByHost, 
standbyPartitionsByHost, fullMetadata);
 
             // ---------------- Step Four ---------------- //