kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch 2.4 updated: HOTFIX: remove reference to unused Assignment error code (#7645)
Date Wed, 06 Nov 2019 01:54:13 GMT
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 <sophie@confluent.io>
AuthorDate: Tue Nov 5 17:53:11 2019 -0800

    HOTFIX: remove reference to unused Assignment error code (#7645)
    
    Reviewers: Guozhang Wang <wangguoz@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");
         }


Mime
View raw message