From dev-return-98861-archive-asf-public=cust-asf.ponee.io@kafka.apache.org Fri Oct 5 21:32:08 2018 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx-eu-01.ponee.io (Postfix) with SMTP id 09A32180677 for ; Fri, 5 Oct 2018 21:32:06 +0200 (CEST) Received: (qmail 14715 invoked by uid 500); 5 Oct 2018 19:32:05 -0000 Mailing-List: contact dev-help@kafka.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@kafka.apache.org Delivered-To: mailing list dev@kafka.apache.org Received: (qmail 14662 invoked by uid 99); 5 Oct 2018 19:32:05 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 05 Oct 2018 19:32:05 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd3-us-west.apache.org (ASF Mail Server at spamd3-us-west.apache.org) with ESMTP id 6EB23180B21 for ; Fri, 5 Oct 2018 19:32:05 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -109.501 X-Spam-Level: X-Spam-Status: No, score=-109.501 tagged_above=-999 required=6.31 tests=[ENV_AND_HDR_SPF_MATCH=-0.5, KAM_ASCII_DIVIDERS=0.8, RCVD_IN_DNSWL_MED=-2.3, SPF_PASS=-0.001, USER_IN_DEF_SPF_WL=-7.5, USER_IN_WHITELIST=-100] autolearn=disabled Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id onuHIRbx6vkS for ; Fri, 5 Oct 2018 19:32:01 +0000 (UTC) Received: from mailrelay1-us-west.apache.org (mailrelay1-us-west.apache.org [209.188.14.139]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTP id 711575F3B3 for ; Fri, 5 Oct 2018 19:32:01 +0000 (UTC) Received: from jira-lw-us.apache.org (unknown [207.244.88.139]) by mailrelay1-us-west.apache.org (ASF Mail Server at mailrelay1-us-west.apache.org) with ESMTP id BB651E0D27 for ; Fri, 5 Oct 2018 19:32:00 +0000 (UTC) Received: from jira-lw-us.apache.org (localhost [127.0.0.1]) by jira-lw-us.apache.org (ASF Mail Server at jira-lw-us.apache.org) with ESMTP id 4FC3324753 for ; Fri, 5 Oct 2018 19:32:00 +0000 (UTC) Date: Fri, 5 Oct 2018 19:32:00 +0000 (UTC) From: "Ryanne Dolan (JIRA)" To: dev@kafka.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Resolved] (KAFKA-6990) CommitFailedException; this task may be no longer owned by the thread 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-6990?page=3Dcom.atlassia= n.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan resolved KAFKA-6990. --------------------------------- Resolution: Not A Bug > CommitFailedException; this task may be no longer owned by the thread > --------------------------------------------------------------------- > > Key: KAFKA-6990 > URL: https://issues.apache.org/jira/browse/KAFKA-6990 > Project: Kafka > Issue Type: Bug > Components: streams > Affects Versions: 0.11.0.1 > Reporter: Eugen Feller > Priority: Blocker > > We are seeing a lot of CommitFailedExceptions on one of our Kafka stream = apps. Running Kafka Streams=C2=A00.11.0.1 and Kafka Broker 0.10.2.1. Full e= rror message: > {code:java} > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] INFO org.apa= che.kafka.streams.KafkaStreams - stream-client [visits-bdb209f1-c9dd-404b-9= 233-064f2fb4227d] State transition from REBALANCING to RUNNING. > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN org.apa= che.kafka.streams.processor.internals.StreamTask - task [0_0] Failed offset= commits {sightings_sighting_byclientmac_0-0=3DOffsetAndMetadata{offset=3D1= 1, metadata=3D''}, mactocontactmappings_contactmapping_byclientmac_0-0=3DOf= fsetAndMetadata{offset=3D26, metadata=3D''}} due to CommitFailedException > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN org.apa= che.kafka.streams.processor.internals.AssignedTasks - stream-thread [visits= -bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] Failed to commit stre= am task 0_0 during commit state due to CommitFailedException; this task may= be no longer owned by the thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN org.apa= che.kafka.streams.processor.internals.AssignedTasks - stream-thread [visits= -bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] Failed to commit stre= am task 0_1 during commit state due to CommitFailedException; this task may= be no longer owned by the thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN org.apa= che.kafka.streams.processor.internals.StreamTask - task [0_1] Failed offset= commits {mactocontactmappings_contactmapping_byclientmac_0-1=3DOffsetAndMe= tadata{offset=3D38, metadata=3D''}, sightings_sighting_byclientmac_0-1=3DOf= fsetAndMetadata{offset=3D1, metadata=3D''}} due to CommitFailedException > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN org.apa= che.kafka.streams.processor.internals.StreamTask - task [0_2] Failed offset= commits {mactocontactmappings_contactmapping_byclientmac_0-2=3DOffsetAndMe= tadata{offset=3D8, metadata=3D''}, sightings_sighting_byclientmac_0-2=3DOff= setAndMetadata{offset=3D24, metadata=3D''}} due to CommitFailedException > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN org.apa= che.kafka.streams.processor.internals.AssignedTasks - stream-thread [visits= -bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] Failed to commit stre= am task 0_2 during commit state due to CommitFailedException; this task may= be no longer owned by the thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN org.apa= che.kafka.streams.processor.internals.StreamTask - task [0_3] Failed offset= commits {sightings_sighting_byclientmac_0-3=3DOffsetAndMetadata{offset=3D2= 1, metadata=3D''}, mactocontactmappings_contactmapping_byclientmac_0-3=3DOf= fsetAndMetadata{offset=3D102, metadata=3D''}} due to CommitFailedException > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN org.apa= che.kafka.streams.processor.internals.AssignedTasks - stream-thread [visits= -bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] Failed to commit stre= am task 0_3 during commit state due to CommitFailedException; this task may= be no longer owned by the thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN org.apa= che.kafka.streams.processor.internals.StreamTask - task [0_4] Failed offset= commits {sightings_sighting_byclientmac_0-4=3DOffsetAndMetadata{offset=3D5= , metadata=3D''}, mactocontactmappings_contactmapping_byclientmac_0-4=3DOff= setAndMetadata{offset=3D20, metadata=3D''}} due to CommitFailedException > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN org.apa= che.kafka.streams.processor.internals.AssignedTasks - stream-thread [visits= -bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] Failed to commit stre= am task 0_4 during commit state due to CommitFailedException; this task may= be no longer owned by the thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN org.apa= che.kafka.streams.processor.internals.StreamTask - task [0_5] Failed offset= commits {mactocontactmappings_contactmapping_byclientmac_0-5=3DOffsetAndMe= tadata{offset=3D26, metadata=3D''}, sightings_sighting_byclientmac_0-5=3DOf= fsetAndMetadata{offset=3D16, metadata=3D''}} due to CommitFailedException > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN org.apa= che.kafka.streams.processor.internals.AssignedTasks - stream-thread [visits= -bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] Failed to commit stre= am task 0_5 during commit state due to CommitFailedException; this task may= be no longer owned by the thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN org.apa= che.kafka.streams.processor.internals.StreamTask - task [0_6] Failed offset= commits {mactocontactmappings_contactmapping_byclientmac_0-6=3DOffsetAndMe= tadata{offset=3D22, metadata=3D''}, sightings_sighting_byclientmac_0-6=3DOf= fsetAndMetadata{offset=3D3, metadata=3D''}} due to CommitFailedException > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN org.apa= che.kafka.streams.processor.internals.AssignedTasks - stream-thread [visits= -bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] Failed to commit stre= am task 0_6 during commit state due to CommitFailedException; this task may= be no longer owned by the thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN org.apa= che.kafka.streams.processor.internals.StreamTask - task [0_7] Failed offset= commits {sightings_sighting_byclientmac_0-7=3DOffsetAndMetadata{offset=3D3= , metadata=3D''}, mactocontactmappings_contactmapping_byclientmac_0-7=3DOff= setAndMetadata{offset=3D5, metadata=3D''}} due to CommitFailedException > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN org.apa= che.kafka.streams.processor.internals.AssignedTasks - stream-thread [visits= -bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] Failed to commit stre= am task 0_7 during commit state due to CommitFailedException; this task may= be no longer owned by the thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN org.apa= che.kafka.streams.processor.internals.AssignedTasks - stream-thread [visits= -bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] Failed to commit stre= am task 0_8 during commit state due to CommitFailedException; this task may= be no longer owned by the thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN org.apa= che.kafka.streams.processor.internals.StreamTask - task [0_8] Failed offset= commits {sightings_sighting_byclientmac_0-8=3DOffsetAndMetadata{offset=3D1= , metadata=3D''}, mactocontactmappings_contactmapping_byclientmac_0-8=3DOff= setAndMetadata{offset=3D3, metadata=3D''}} due to CommitFailedException > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN org.apa= che.kafka.streams.processor.internals.StreamTask - task [0_9] Failed offset= commits {mactocontactmappings_contactmapping_byclientmac_0-9=3DOffsetAndMe= tadata{offset=3D115, metadata=3D''}, sightings_sighting_byclientmac_0-9=3DO= ffsetAndMetadata{offset=3D1, metadata=3D''}} due to CommitFailedException > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN org.apa= che.kafka.streams.processor.internals.AssignedTasks - stream-thread [visits= -bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] Failed to commit stre= am task 0_9 during commit state due to CommitFailedException; this task may= be no longer owned by the thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN org.apa= che.kafka.streams.processor.internals.StreamTask - task [0_10] Failed offse= t commits {mactocontactmappings_contactmapping_byclientmac_0-10=3DOffsetAnd= Metadata{offset=3D22, metadata=3D''}, sightings_sighting_byclientmac_0-10= =3DOffsetAndMetadata{offset=3D2, metadata=3D''}} due to CommitFailedExcepti= on > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN org.apa= che.kafka.streams.processor.internals.AssignedTasks - stream-thread [visits= -bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] Failed to commit stre= am task 0_10 during commit state due to CommitFailedException; this task ma= y be no longer owned by the thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN org.apa= che.kafka.streams.processor.internals.AssignedTasks - stream-thread [visits= -bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] Failed to commit stre= am task 0_11 during commit state due to CommitFailedException; this task ma= y be no longer owned by the thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN org.apa= che.kafka.streams.processor.internals.StreamTask - task [0_11] Failed offse= t commits {mactocontactmappings_contactmapping_byclientmac_0-11=3DOffsetAnd= Metadata{offset=3D20, metadata=3D''}} due to CommitFailedException > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN org.apa= che.kafka.streams.processor.internals.StreamTask - task [0_12] Failed offse= t commits {sightings_sighting_byclientmac_0-12=3DOffsetAndMetadata{offset= =3D1, metadata=3D''}, mactocontactmappings_contactmapping_byclientmac_0-12= =3DOffsetAndMetadata{offset=3D38, metadata=3D''}} due to CommitFailedExcept= ion > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN org.apa= che.kafka.streams.processor.internals.AssignedTasks - stream-thread [visits= -bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] Failed to commit stre= am task 0_12 during commit state due to CommitFailedException; this task ma= y be no longer owned by the thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN org.apa= che.kafka.streams.processor.internals.StreamTask - task [0_13] Failed offse= t commits {mactocontactmappings_contactmapping_byclientmac_0-13=3DOffsetAnd= Metadata{offset=3D17, metadata=3D''}, sightings_sighting_byclientmac_0-13= =3DOffsetAndMetadata{offset=3D13, metadata=3D''}} due to CommitFailedExcept= ion > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN org.apa= che.kafka.streams.processor.internals.AssignedTasks - stream-thread [visits= -bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] Failed to commit stre= am task 0_13 during commit state due to CommitFailedException; this task ma= y be no longer owned by the thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN org.apa= che.kafka.streams.processor.internals.StreamTask - task [0_14] Failed offse= t commits {mactocontactmappings_contactmapping_byclientmac_0-14=3DOffsetAnd= Metadata{offset=3D2, metadata=3D''}, sightings_sighting_byclientmac_0-14=3D= OffsetAndMetadata{offset=3D1, metadata=3D''}} due to CommitFailedException > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN org.apa= che.kafka.streams.processor.internals.AssignedTasks - stream-thread [visits= -bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] Failed to commit stre= am task 0_14 during commit state due to CommitFailedException; this task ma= y be no longer owned by the thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN org.apa= che.kafka.streams.processor.internals.StreamTask - task [0_15] Failed offse= t commits {sightings_sighting_byclientmac_0-15=3DOffsetAndMetadata{offset= =3D14, metadata=3D''}, mactocontactmappings_contactmapping_byclientmac_0-15= =3DOffsetAndMetadata{offset=3D69, metadata=3D''}} due to CommitFailedExcept= ion > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN org.apa= che.kafka.streams.processor.internals.AssignedTasks - stream-thread [visits= -bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] Failed to commit stre= am task 0_15 during commit state due to CommitFailedException; this task ma= y be no longer owned by the thread > {code} > =C2=A0 > Same app also keeps rebalancing non stop: > {code:java} > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] INFO org.apa= che.kafka.streams.processor.internals.StreamThread - stream-thread [visits-= bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] partition revocation t= ook 2354 ms. > suspended active tasks: [0_0, 0_1, 1_0, 0_2, 1_1, 0_3, 1_2, 0_4, 1_3, 0_5= , 1_4, 0_6, 1_5, 0_7, 1_6, 0_8, 1_7, 0_9, 1_8, 0_10, 1_9, 0_11, 1_10, 0_12,= 1_11, 0_13, 1_12, 0_14, 1_13, 0_15, 1_14, 1_15] > suspended standby tasks: [] > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] INFO org.apa= che.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining gro= up visits > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] INFO org.apa= che.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joi= ned group visits with generation 973 > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] INFO org.apa= che.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly as= signed partitions [sightings_sighting_byclientmac_0-16, mactocontactmapping= s_contactmapping_byclientmac_0-25, sightings_sighting_byclientmac_0-20, mac= tocontactmappings_contactmapping_byclientmac_0-21, mactocontactmappings_con= tactmapping_byclientmac_0-29, visits_enrichedsighting_byclientmac_0-19, vis= its_enrichedsighting_byclientmac_0-23, sightings_sighting_byclientmac_0-25,= mactocontactmappings_contactmapping_byclientmac_0-16, visits_enrichedsight= ing_byclientmac_0-27, sightings_sighting_byclientmac_0-29, visits_enricheds= ighting_byclientmac_0-31, mactocontactmappings_contactmapping_byclientmac_0= -26, sightings_sighting_byclientmac_0-19, mactocontactmappings_contactmappi= ng_byclientmac_0-22, mactocontactmappings_contactmapping_byclientmac_0-30, = visits_enrichedsighting_byclientmac_0-16, visits_enrichedsighting_byclientm= ac_0-20, visits_enrichedsighting_byclientmac_0-24, sightings_sighting_bycli= entmac_0-24, mactocontactmappings_contactmapping_byclientmac_0-17, visits_e= nrichedsighting_byclientmac_0-28, sightings_sighting_byclientmac_0-28, sigh= tings_sighting_byclientmac_0-18, mactocontactmappings_contactmapping_byclie= ntmac_0-23, sightings_sighting_byclientmac_0-22, mactocontactmappings_conta= ctmapping_byclientmac_0-19, mactocontactmappings_contactmapping_byclientmac= _0-31, mactocontactmappings_contactmapping_byclientmac_0-27, sightings_sigh= ting_byclientmac_0-31, visits_enrichedsighting_byclientmac_0-17, visits_enr= ichedsighting_byclientmac_0-21, sightings_sighting_byclientmac_0-23, mactoc= ontactmappings_contactmapping_byclientmac_0-18, visits_enrichedsighting_byc= lientmac_0-25, sightings_sighting_byclientmac_0-27, visits_enrichedsighting= _byclientmac_0-29, sightings_sighting_byclientmac_0-17, mactocontactmapping= s_contactmapping_byclientmac_0-24, sightings_sighting_byclientmac_0-21, mac= tocontactmappings_contactmapping_byclientmac_0-20, mactocontactmappings_con= tactmapping_byclientmac_0-28, visits_enrichedsighting_byclientmac_0-18, vis= its_enrichedsighting_byclientmac_0-22, visits_enrichedsighting_byclientmac_= 0-26, sightings_sighting_byclientmac_0-26, visits_enrichedsighting_byclient= mac_0-30, sightings_sighting_byclientmac_0-30] for group visits > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] INFO org.apa= che.kafka.streams.processor.internals.StreamThread - stream-thread [visits-= bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] State transition from = PARTITIONS_REVOKED to PARTITIONS_ASSIGNED. > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] INFO org.apa= che.kafka.streams.KafkaStreams - stream-client [visits-bdb209f1-c9dd-404b-9= 233-064f2fb4227d] State transition from REBALANCING to REBALANCING. > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] INFO org.apa= che.kafka.streams.processor.internals.StreamThread - stream-thread [visits-= bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] partition assignment t= ook 340 ms. > current active tasks: [0_16, 0_17, 1_16, 0_18, 1_17, 0_19, 1_18, 0_20, 1_= 19, 0_21, 1_20, 0_22, 1_21, 0_23, 1_22, 0_24, 1_23, 0_25, 1_24, 0_26, 1_25,= 0_27, 1_26, 0_28, 1_27, 0_29, 1_28, 0_30, 1_29, 0_31, 1_30, 1_31] > current standby tasks: [] > previous active tasks: [0_0, 0_1, 1_0, 0_2, 1_1, 0_3, 1_2, 0_4, 1_3, 0_5,= 1_4, 0_6, 1_5, 0_7, 1_6, 0_8, 1_7, 0_9, 1_8, 0_10, 1_9, 0_11, 1_10, 0_12, = 1_11, 0_13, 1_12, 0_14, 1_13, 0_15, 1_14, 1_15] > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] INFO org.apa= che.kafka.streams.processor.internals.StreamThread - stream-thread [visits-= bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] State transition from = PARTITIONS_ASSIGNED to RUNNING. > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] INFO org.apa= che.kafka.streams.KafkaStreams - stream-client [visits-bdb209f1-c9dd-404b-9= 233-064f2fb4227d] State transition from REBALANCING to RUNNING. > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] INFO org.apa= che.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previou= sly assigned partitions [sightings_sighting_byclientmac_0-16, mactocontactm= appings_contactmapping_byclientmac_0-25, sightings_sighting_byclientmac_0-2= 0, mactocontactmappings_contactmapping_byclientmac_0-21, mactocontactmappin= gs_contactmapping_byclientmac_0-29, visits_enrichedsighting_byclientmac_0-1= 9, visits_enrichedsighting_byclientmac_0-23, sightings_sighting_byclientmac= _0-25, mactocontactmappings_contactmapping_byclientmac_0-16, visits_enriche= dsighting_byclientmac_0-27, sightings_sighting_byclientmac_0-29, visits_enr= ichedsighting_byclientmac_0-31, mactocontactmappings_contactmapping_byclien= tmac_0-26, sightings_sighting_byclientmac_0-19, mactocontactmappings_contac= tmapping_byclientmac_0-22, mactocontactmappings_contactmapping_byclientmac_= 0-30, visits_enrichedsighting_byclientmac_0-16, visits_enrichedsighting_byc= lientmac_0-20, visits_enrichedsighting_byclientmac_0-24, sightings_sighting= _byclientmac_0-24, mactocontactmappings_contactmapping_byclientmac_0-17, vi= sits_enrichedsighting_byclientmac_0-28, sightings_sighting_byclientmac_0-28= , sightings_sighting_byclientmac_0-18, mactocontactmappings_contactmapping_= byclientmac_0-23, sightings_sighting_byclientmac_0-22, mactocontactmappings= _contactmapping_byclientmac_0-19, mactocontactmappings_contactmapping_bycli= entmac_0-31, mactocontactmappings_contactmapping_byclientmac_0-27, sighting= s_sighting_byclientmac_0-31, visits_enrichedsighting_byclientmac_0-17, visi= ts_enrichedsighting_byclientmac_0-21, sightings_sighting_byclientmac_0-23, = mactocontactmappings_contactmapping_byclientmac_0-18, visits_enrichedsighti= ng_byclientmac_0-25, sightings_sighting_byclientmac_0-27, visits_enrichedsi= ghting_byclientmac_0-29, sightings_sighting_byclientmac_0-17, mactocontactm= appings_contactmapping_byclientmac_0-24, sightings_sighting_byclientmac_0-2= 1, mactocontactmappings_contactmapping_byclientmac_0-20, mactocontactmappin= gs_contactmapping_byclientmac_0-28, visits_enrichedsighting_byclientmac_0-1= 8, visits_enrichedsighting_byclientmac_0-22, visits_enrichedsighting_byclie= ntmac_0-26, sightings_sighting_byclientmac_0-26, visits_enrichedsighting_by= clientmac_0-30, sightings_sighting_byclientmac_0-30] for group visits > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] INFO org.apa= che.kafka.streams.processor.internals.StreamThread - stream-thread [visits-= bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] State transition from = RUNNING to PARTITIONS_REVOKED. > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] INFO org.apa= che.kafka.streams.KafkaStreams - stream-client [visits-bdb209f1-c9dd-404b-9= 233-064f2fb4227d] State transition from RUNNING to REBALANCING. > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] INFO org.apa= che.kafka.streams.processor.internals.StreamThread - stream-thread [visits-= bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] partition revocation t= ook 951 ms. > suspended active tasks: [0_16, 1_16, 0_17, 1_17, 0_18, 1_18, 0_19, 1_19, = 0_20, 1_20, 0_21, 1_21, 0_22, 1_22, 0_23, 1_23, 0_24, 1_24, 0_25, 1_25, 0_2= 6, 1_26, 0_27, 1_27, 0_28, 1_28, 0_29, 1_29, 0_30, 1_30, 0_31, 1_31] > suspended standby tasks: [] > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] INFO org.apa= che.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining gro= up visits > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] INFO org.apa= che.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joi= ned group visits with generation 974{code} > Any idea what could be going on? This service is only running with 2 inst= ances (each one stream thread). -- This message was sent by Atlassian JIRA (v7.6.3#76005)