You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2019/11/06 01:54:13 UTC

[kafka] branch 2.4 updated: HOTFIX: remove reference to unused Assignment error code (#7645)

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

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


The following commit(s) were added to refs/heads/2.4 by this push:
     new 198b28f  HOTFIX: remove reference to unused Assignment error code (#7645)
198b28f is described below

commit 198b28f609cdefe7466006f91d9ec188aa13f516
Author: A. Sophie Blee-Goldman <so...@confluent.io>
AuthorDate: Tue Nov 5 17:53:11 2019 -0800

    HOTFIX: remove reference to unused Assignment error code (#7645)
    
    Reviewers: Guozhang Wang <wa...@gmail.com>
---
 .../apache/kafka/clients/consumer/internals/ConsumerCoordinator.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java
index 61bd48a..142b1a1 100644
--- a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java
+++ b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java
@@ -622,7 +622,7 @@ public final class ConsumerCoordinator extends AbstractCoordinator {
         if (!totalAddedPartitions.isEmpty()) {
             log.error("With the COOPERATIVE protocol, owned partitions cannot be " +
                 "reassigned to other members; however the assignor has reassigned partitions {} which are still owned " +
-                "by some members; return the error code to all members to let them stop", totalAddedPartitions);
+                "by some members", totalAddedPartitions);
 
             throw new IllegalStateException("Assignor supporting the COOPERATIVE protocol violates its requirements");
         }