[
https://issues.apache.org/jira/browse/KAFKA-17960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17903789#comment-17903789
]
Kirk True commented on KAFKA-17960:
-----------------------------------
It doesn't appear that KAFKA-18116 fixed this. I just re-ran the test (locally)
against {{trunk}} and I get this error:
{noformat}
java.lang.IllegalArgumentException: Member "MemberIdentity(memberId='',
groupInstanceId='test_instance_id_1', reason=null)" was not included in the
removal response
java.util.concurrent.ExecutionException: java.lang.IllegalArgumentException:
Member "MemberIdentity(memberId='', groupInstanceId='test_instance_id_1',
reason=null)" was not included in the removal response
at
java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396)
at
java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073)
at
org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:155)
at
kafka.api.PlaintextAdminIntegrationTest.testConsumerGroups(PlaintextAdminIntegrationTest.scala:2004)
at java.base/java.lang.reflect.Method.invoke(Method.java:569)
at
java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
at
java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
at
java.base/java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:179)
at
java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
at
java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
at
java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
at
java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
at
java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
at
java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
at
java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
at
java.base/java.util.Spliterators$ArraySpliterator.forEachRemaining(Spliterators.java:992)
at
java.base/java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:762)
at
java.base/java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:276)
at
java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
at
java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
at
java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
at
java.base/java.util.Spliterators$ArraySpliterator.forEachRemaining(Spliterators.java:992)
at
java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
at
java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
at
java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
at
java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
at
java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
at
java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596)
at
java.base/java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:276)
at
java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
at
java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
at
java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
at
java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1625)
at
java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
at
java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
at
java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
at
java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
at
java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
at
java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596)
at
java.base/java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:276)
at
java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1625)
at
java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
at
java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
at
java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
at
java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
at
java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
at
java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
Caused by: java.lang.IllegalArgumentException: Member
"MemberIdentity(memberId='', groupInstanceId='test_instance_id_1',
reason=null)" was not included in the removal response
at
org.apache.kafka.clients.admin.KafkaAdminClient.getSubLevelError(KafkaAdminClient.java:5006)
at
org.apache.kafka.clients.admin.RemoveMembersFromConsumerGroupResult.maybeCompleteExceptionally(RemoveMembersFromConsumerGroupResult.java:103)
at
org.apache.kafka.clients.admin.RemoveMembersFromConsumerGroupResult.lambda$all$0(RemoveMembersFromConsumerGroupResult.java:67)
at
org.apache.kafka.common.internals.KafkaFutureImpl.lambda$whenComplete$2(KafkaFutureImpl.java:97)
at
java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:863)
at
java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:841)
at
java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510)
at
java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2147)
at
org.apache.kafka.common.internals.KafkaCompletableFuture.kafkaComplete(KafkaCompletableFuture.java:39)
at
org.apache.kafka.common.internals.KafkaFutureImpl.complete(KafkaFutureImpl.java:112)
at
org.apache.kafka.clients.admin.internals.AdminApiFuture$SimpleAdminApiFuture.complete(AdminApiFuture.java:120)
at
java.base/java.util.Collections$SingletonMap.forEach(Collections.java:5061)
at
java.base/java.util.Collections$UnmodifiableMap.forEach(Collections.java:1553)
at
org.apache.kafka.clients.admin.internals.AdminApiFuture$SimpleAdminApiFuture.complete(AdminApiFuture.java:116)
at
org.apache.kafka.clients.admin.internals.AdminApiDriver.complete(AdminApiDriver.java:192)
at
org.apache.kafka.clients.admin.internals.AdminApiDriver.onResponse(AdminApiDriver.java:236)
at
org.apache.kafka.clients.admin.KafkaAdminClient$38.handleResponse(KafkaAdminClient.java:4957)
at
org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.handleResponses(KafkaAdminClient.java:1417)
at
org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.processRequests(KafkaAdminClient.java:1571)
at
org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.run(KafkaAdminClient.java:1494)
at java.base/java.lang.Thread.run(Thread.java:840)
{noformat}
> PlaintextAdminIntegrationTest.testConsumerGroups fails with CONSUMER group
> protocol
> -----------------------------------------------------------------------------------
>
> Key: KAFKA-17960
> URL: https://issues.apache.org/jira/browse/KAFKA-17960
> Project: Kafka
> Issue Type: Bug
> Components: admin, clients, consumer
> Affects Versions: 3.9.0
> Reporter: Kirk True
> Assignee: Lin Siyuan
> Priority: Major
> Labels: integration-test, kip-848-client-support
> Fix For: 4.0.0
>
>
> When executing the {{PlaintextAdminIntegrationTest}}'s
> {{testConsumerGroups()}} using the {{CONSUMER}} group protocol, it fails with
> the error:
> {quote}{color:#FF0000}Expected the offset for partition 0 to eventually
> become 1.{color}
> {quote}
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
