From jira-return-58747-archive-asf-public=cust-asf.ponee.io@kafka.apache.org Tue Dec 8 08:41:33 2020 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mxout1-ec2-va.apache.org (mxout1-ec2-va.apache.org [3.227.148.255]) by mx-eu-01.ponee.io (Postfix) with ESMTPS id 7B46218064A for ; Tue, 8 Dec 2020 09:41:33 +0100 (CET) Received: from mail.apache.org (mailroute1-lw-us.apache.org [207.244.88.153]) by mxout1-ec2-va.apache.org (ASF Mail Server at mxout1-ec2-va.apache.org) with SMTP id B2709480C3 for ; Tue, 8 Dec 2020 08:41:32 +0000 (UTC) Received: (qmail 95227 invoked by uid 500); 8 Dec 2020 08:41:32 -0000 Mailing-List: contact jira-help@kafka.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: jira@kafka.apache.org Delivered-To: mailing list jira@kafka.apache.org Received: (qmail 95047 invoked by uid 99); 8 Dec 2020 08:41:32 -0000 Received: from mailrelay1-he-de.apache.org (HELO mailrelay1-he-de.apache.org) (116.203.21.61) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 08 Dec 2020 08:41:32 +0000 Received: from jira2-he-de.apache.org (jira2-he-de.apache.org [168.119.33.54]) by mailrelay1-he-de.apache.org (ASF Mail Server at mailrelay1-he-de.apache.org) with ESMTPS id 3A9B73EA7E for ; Tue, 8 Dec 2020 08:41:31 +0000 (UTC) Received: from jira2-he-de.apache.org (localhost.localdomain [127.0.0.1]) by jira2-he-de.apache.org (ASF Mail Server at jira2-he-de.apache.org) with ESMTP id 47EF5C8065A for ; Tue, 8 Dec 2020 08:41:00 +0000 (UTC) Date: Tue, 8 Dec 2020 08:41:00 +0000 (UTC) From: "Levani Kokhreidze (Jira)" To: jira@kafka.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (KAFKA-10772) java.lang.IllegalStateException: There are insufficient bytes available to read assignment from the sync-group response (actual byte size 0) MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: quoted-printable X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 [ https://issues.apache.org/jira/browse/KAFKA-10772?page=3Dcom.atlassia= n.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=3D172= 45744#comment-17245744 ]=20 Levani Kokhreidze commented on KAFKA-10772: ------------------------------------------- Hi [~ableegoldman], =C2=A0 Sorry, got a bit distracted. I'll see what I can find and try to add additi= onal logs.=C2=A0 > java.lang.IllegalStateException: There are insufficient bytes available t= o read assignment from the sync-group response (actual byte size 0) > -------------------------------------------------------------------------= ------------------------------------------------------------------- > > Key: KAFKA-10772 > URL: https://issues.apache.org/jira/browse/KAFKA-10772 > Project: Kafka > Issue Type: Bug > Components: streams > Affects Versions: 2.6.0 > Reporter: Levani Kokhreidze > Priority: Blocker > Attachments: KAFKA-10772.log > > > From time to time we encounter the following exception that results in Ka= fka Streams threads dying. > Broker version 2.4.1, Client version 2.6.0 > {code:java} > Nov 27 00:59:53.681 streaming-app service: prod | streaming-app-2 | strea= m-client [cluster1-profile-stats-pipeline-client-id] State transition from = REBALANCING to ERROR=C2=A0Nov 27 00:59:53.681 streaming-app service: prod |= streaming-app-2 | stream-client [cluster1-profile-stats-pipeline-client-id= ] State transition from REBALANCING to ERROR=C2=A0Nov 27 00:59:53.682 strea= ming-app service: prod | streaming-app-2 | 2020-11-27 00:59:53.681 ERROR 10= 5 --- [-StreamThread-1] .KafkaStreamsBasedStreamProcessingEngine : Stream p= rocessing pipeline: [profile-stats] encountered unrecoverable exception. Th= read: [cluster1-profile-stats-pipeline-client-id-StreamThread-1] is complet= ely dead. If all worker threads die, Kafka Streams will be moved to permane= nt ERROR state.=C2=A0Nov 27 00:59:53.682 streaming-app service: prod | stre= aming-app-2 | Stream processing pipeline: [profile-stats] encountered unrec= overable exception. Thread: [cluster1-profile-stats-pipeline-client-id-Stre= amThread-1] is completely dead. If all worker threads die, Kafka Streams wi= ll be moved to permanent ERROR state. java.lang.IllegalStateException: Ther= e are insufficient bytes available to read assignment from the sync-group r= esponse (actual byte size 0) , this is not expected; it is possible that th= e leader's assign function is buggy and did not return any assignment for t= his member, or because static member is configured and the protocol is bugg= y hence did not get the assignment for this member at org.apache.kafka.clie= nts.consumer.internals.ConsumerCoordinator.onJoinComplete(ConsumerCoordinat= or.java:367) at org.apache.kafka.clients.consumer.internals.AbstractCoordin= ator.joinGroupIfNeeded(AbstractCoordinator.java:440) at org.apache.kafka.cl= ients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoor= dinator.java:359) at org.apache.kafka.clients.consumer.internals.ConsumerCo= ordinator.poll(ConsumerCoordinator.java:513) at org.apache.kafka.clients.co= nsumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:12= 68) at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.j= ava:1230) at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaCons= umer.java:1210) at org.apache.kafka.streams.processor.internals.StreamThrea= d.pollRequests(StreamThread.java:766) at org.apache.kafka.streams.processor= .internals.StreamThread.runOnce(StreamThread.java:624) at org.apache.kafka.= streams.processor.internals.StreamThread.runLoop(StreamThread.java:551) at = org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.= java:510) > {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)