[ https://issues.apache.org/jira/browse/KAFKA-6990?page=com.atlassian.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 0.11.0.1 and Kafka Broker 0.10.2.1. Full error > message: > {code:java} > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] INFO > org.apache.kafka.streams.KafkaStreams - stream-client > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d] State transition from > REBALANCING to RUNNING. > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN > org.apache.kafka.streams.processor.internals.StreamTask - task [0_0] Failed > offset commits > {sightings_sighting_byclientmac_0-0=OffsetAndMetadata{offset=11, > metadata=''}, > mactocontactmappings_contactmapping_byclientmac_0-0=OffsetAndMetadata{offset=26, > metadata=''}} due to CommitFailedException > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN > org.apache.kafka.streams.processor.internals.AssignedTasks - stream-thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] Failed to commit > stream 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.apache.kafka.streams.processor.internals.AssignedTasks - stream-thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] Failed to commit > stream 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.apache.kafka.streams.processor.internals.StreamTask - task [0_1] Failed > offset commits > {mactocontactmappings_contactmapping_byclientmac_0-1=OffsetAndMetadata{offset=38, > metadata=''}, sightings_sighting_byclientmac_0-1=OffsetAndMetadata{offset=1, > metadata=''}} due to CommitFailedException > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN > org.apache.kafka.streams.processor.internals.StreamTask - task [0_2] Failed > offset commits > {mactocontactmappings_contactmapping_byclientmac_0-2=OffsetAndMetadata{offset=8, > metadata=''}, > sightings_sighting_byclientmac_0-2=OffsetAndMetadata{offset=24, metadata=''}} > due to CommitFailedException > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN > org.apache.kafka.streams.processor.internals.AssignedTasks - stream-thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] Failed to commit > stream 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.apache.kafka.streams.processor.internals.StreamTask - task [0_3] Failed > offset commits > {sightings_sighting_byclientmac_0-3=OffsetAndMetadata{offset=21, > metadata=''}, > mactocontactmappings_contactmapping_byclientmac_0-3=OffsetAndMetadata{offset=102, > metadata=''}} due to CommitFailedException > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN > org.apache.kafka.streams.processor.internals.AssignedTasks - stream-thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] Failed to commit > stream 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.apache.kafka.streams.processor.internals.StreamTask - task [0_4] Failed > offset commits > {sightings_sighting_byclientmac_0-4=OffsetAndMetadata{offset=5, metadata=''}, > mactocontactmappings_contactmapping_byclientmac_0-4=OffsetAndMetadata{offset=20, > metadata=''}} due to CommitFailedException > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN > org.apache.kafka.streams.processor.internals.AssignedTasks - stream-thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] Failed to commit > stream 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.apache.kafka.streams.processor.internals.StreamTask - task [0_5] Failed > offset commits > {mactocontactmappings_contactmapping_byclientmac_0-5=OffsetAndMetadata{offset=26, > metadata=''}, > sightings_sighting_byclientmac_0-5=OffsetAndMetadata{offset=16, metadata=''}} > due to CommitFailedException > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN > org.apache.kafka.streams.processor.internals.AssignedTasks - stream-thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] Failed to commit > stream 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.apache.kafka.streams.processor.internals.StreamTask - task [0_6] Failed > offset commits > {mactocontactmappings_contactmapping_byclientmac_0-6=OffsetAndMetadata{offset=22, > metadata=''}, sightings_sighting_byclientmac_0-6=OffsetAndMetadata{offset=3, > metadata=''}} due to CommitFailedException > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN > org.apache.kafka.streams.processor.internals.AssignedTasks - stream-thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] Failed to commit > stream 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.apache.kafka.streams.processor.internals.StreamTask - task [0_7] Failed > offset commits > {sightings_sighting_byclientmac_0-7=OffsetAndMetadata{offset=3, metadata=''}, > mactocontactmappings_contactmapping_byclientmac_0-7=OffsetAndMetadata{offset=5, > metadata=''}} due to CommitFailedException > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN > org.apache.kafka.streams.processor.internals.AssignedTasks - stream-thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] Failed to commit > stream 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.apache.kafka.streams.processor.internals.AssignedTasks - stream-thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] Failed to commit > stream 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.apache.kafka.streams.processor.internals.StreamTask - task [0_8] Failed > offset commits > {sightings_sighting_byclientmac_0-8=OffsetAndMetadata{offset=1, metadata=''}, > mactocontactmappings_contactmapping_byclientmac_0-8=OffsetAndMetadata{offset=3, > metadata=''}} due to CommitFailedException > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN > org.apache.kafka.streams.processor.internals.StreamTask - task [0_9] Failed > offset commits > {mactocontactmappings_contactmapping_byclientmac_0-9=OffsetAndMetadata{offset=115, > metadata=''}, sightings_sighting_byclientmac_0-9=OffsetAndMetadata{offset=1, > metadata=''}} due to CommitFailedException > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN > org.apache.kafka.streams.processor.internals.AssignedTasks - stream-thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] Failed to commit > stream 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.apache.kafka.streams.processor.internals.StreamTask - task [0_10] Failed > offset commits > {mactocontactmappings_contactmapping_byclientmac_0-10=OffsetAndMetadata{offset=22, > metadata=''}, > sightings_sighting_byclientmac_0-10=OffsetAndMetadata{offset=2, metadata=''}} > due to CommitFailedException > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN > org.apache.kafka.streams.processor.internals.AssignedTasks - stream-thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] Failed to commit > stream task 0_10 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.apache.kafka.streams.processor.internals.AssignedTasks - stream-thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] Failed to commit > stream task 0_11 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.apache.kafka.streams.processor.internals.StreamTask - task [0_11] Failed > offset commits > {mactocontactmappings_contactmapping_byclientmac_0-11=OffsetAndMetadata{offset=20, > metadata=''}} due to CommitFailedException > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN > org.apache.kafka.streams.processor.internals.StreamTask - task [0_12] Failed > offset commits > {sightings_sighting_byclientmac_0-12=OffsetAndMetadata{offset=1, > metadata=''}, > mactocontactmappings_contactmapping_byclientmac_0-12=OffsetAndMetadata{offset=38, > metadata=''}} due to CommitFailedException > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN > org.apache.kafka.streams.processor.internals.AssignedTasks - stream-thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] Failed to commit > stream task 0_12 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.apache.kafka.streams.processor.internals.StreamTask - task [0_13] Failed > offset commits > {mactocontactmappings_contactmapping_byclientmac_0-13=OffsetAndMetadata{offset=17, > metadata=''}, > sightings_sighting_byclientmac_0-13=OffsetAndMetadata{offset=13, > metadata=''}} due to CommitFailedException > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN > org.apache.kafka.streams.processor.internals.AssignedTasks - stream-thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] Failed to commit > stream task 0_13 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.apache.kafka.streams.processor.internals.StreamTask - task [0_14] Failed > offset commits > {mactocontactmappings_contactmapping_byclientmac_0-14=OffsetAndMetadata{offset=2, > metadata=''}, > sightings_sighting_byclientmac_0-14=OffsetAndMetadata{offset=1, metadata=''}} > due to CommitFailedException > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN > org.apache.kafka.streams.processor.internals.AssignedTasks - stream-thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] Failed to commit > stream task 0_14 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.apache.kafka.streams.processor.internals.StreamTask - task [0_15] Failed > offset commits > {sightings_sighting_byclientmac_0-15=OffsetAndMetadata{offset=14, > metadata=''}, > mactocontactmappings_contactmapping_byclientmac_0-15=OffsetAndMetadata{offset=69, > metadata=''}} due to CommitFailedException > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] WARN > org.apache.kafka.streams.processor.internals.AssignedTasks - stream-thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] Failed to commit > stream task 0_15 during commit state due to CommitFailedException; this task > may be no longer owned by the thread > {code} > > Same app also keeps rebalancing non stop: > {code:java} > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] INFO > org.apache.kafka.streams.processor.internals.StreamThread - stream-thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] partition > revocation took 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.apache.kafka.clients.consumer.internals.AbstractCoordinator - > (Re-)joining group visits > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] INFO > org.apache.kafka.clients.consumer.internals.AbstractCoordinator - > Successfully joined group visits with generation 973 > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] INFO > org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting > newly assigned partitions [sightings_sighting_byclientmac_0-16, > mactocontactmappings_contactmapping_byclientmac_0-25, > sightings_sighting_byclientmac_0-20, > mactocontactmappings_contactmapping_byclientmac_0-21, > mactocontactmappings_contactmapping_byclientmac_0-29, > visits_enrichedsighting_byclientmac_0-19, > visits_enrichedsighting_byclientmac_0-23, > sightings_sighting_byclientmac_0-25, > mactocontactmappings_contactmapping_byclientmac_0-16, > visits_enrichedsighting_byclientmac_0-27, > sightings_sighting_byclientmac_0-29, > visits_enrichedsighting_byclientmac_0-31, > mactocontactmappings_contactmapping_byclientmac_0-26, > sightings_sighting_byclientmac_0-19, > mactocontactmappings_contactmapping_byclientmac_0-22, > mactocontactmappings_contactmapping_byclientmac_0-30, > visits_enrichedsighting_byclientmac_0-16, > visits_enrichedsighting_byclientmac_0-20, > visits_enrichedsighting_byclientmac_0-24, > sightings_sighting_byclientmac_0-24, > mactocontactmappings_contactmapping_byclientmac_0-17, > visits_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_byclientmac_0-31, > mactocontactmappings_contactmapping_byclientmac_0-27, > sightings_sighting_byclientmac_0-31, > visits_enrichedsighting_byclientmac_0-17, > visits_enrichedsighting_byclientmac_0-21, > sightings_sighting_byclientmac_0-23, > mactocontactmappings_contactmapping_byclientmac_0-18, > visits_enrichedsighting_byclientmac_0-25, > sightings_sighting_byclientmac_0-27, > visits_enrichedsighting_byclientmac_0-29, > sightings_sighting_byclientmac_0-17, > mactocontactmappings_contactmapping_byclientmac_0-24, > sightings_sighting_byclientmac_0-21, > mactocontactmappings_contactmapping_byclientmac_0-20, > mactocontactmappings_contactmapping_byclientmac_0-28, > visits_enrichedsighting_byclientmac_0-18, > visits_enrichedsighting_byclientmac_0-22, > visits_enrichedsighting_byclientmac_0-26, > sightings_sighting_byclientmac_0-26, > visits_enrichedsighting_byclientmac_0-30, > sightings_sighting_byclientmac_0-30] for group visits > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] INFO > org.apache.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.apache.kafka.streams.KafkaStreams - stream-client > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d] State transition from > REBALANCING to REBALANCING. > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] INFO > org.apache.kafka.streams.processor.internals.StreamThread - stream-thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] partition > assignment took 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.apache.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.apache.kafka.streams.KafkaStreams - stream-client > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d] State transition from > REBALANCING to RUNNING. > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] INFO > org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking > previously assigned partitions [sightings_sighting_byclientmac_0-16, > mactocontactmappings_contactmapping_byclientmac_0-25, > sightings_sighting_byclientmac_0-20, > mactocontactmappings_contactmapping_byclientmac_0-21, > mactocontactmappings_contactmapping_byclientmac_0-29, > visits_enrichedsighting_byclientmac_0-19, > visits_enrichedsighting_byclientmac_0-23, > sightings_sighting_byclientmac_0-25, > mactocontactmappings_contactmapping_byclientmac_0-16, > visits_enrichedsighting_byclientmac_0-27, > sightings_sighting_byclientmac_0-29, > visits_enrichedsighting_byclientmac_0-31, > mactocontactmappings_contactmapping_byclientmac_0-26, > sightings_sighting_byclientmac_0-19, > mactocontactmappings_contactmapping_byclientmac_0-22, > mactocontactmappings_contactmapping_byclientmac_0-30, > visits_enrichedsighting_byclientmac_0-16, > visits_enrichedsighting_byclientmac_0-20, > visits_enrichedsighting_byclientmac_0-24, > sightings_sighting_byclientmac_0-24, > mactocontactmappings_contactmapping_byclientmac_0-17, > visits_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_byclientmac_0-31, > mactocontactmappings_contactmapping_byclientmac_0-27, > sightings_sighting_byclientmac_0-31, > visits_enrichedsighting_byclientmac_0-17, > visits_enrichedsighting_byclientmac_0-21, > sightings_sighting_byclientmac_0-23, > mactocontactmappings_contactmapping_byclientmac_0-18, > visits_enrichedsighting_byclientmac_0-25, > sightings_sighting_byclientmac_0-27, > visits_enrichedsighting_byclientmac_0-29, > sightings_sighting_byclientmac_0-17, > mactocontactmappings_contactmapping_byclientmac_0-24, > sightings_sighting_byclientmac_0-21, > mactocontactmappings_contactmapping_byclientmac_0-20, > mactocontactmappings_contactmapping_byclientmac_0-28, > visits_enrichedsighting_byclientmac_0-18, > visits_enrichedsighting_byclientmac_0-22, > visits_enrichedsighting_byclientmac_0-26, > sightings_sighting_byclientmac_0-26, > visits_enrichedsighting_byclientmac_0-30, > sightings_sighting_byclientmac_0-30] for group visits > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] INFO > org.apache.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.apache.kafka.streams.KafkaStreams - stream-client > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d] State transition from RUNNING > to REBALANCING. > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] INFO > org.apache.kafka.streams.processor.internals.StreamThread - stream-thread > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] partition > revocation took 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_26, > 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.apache.kafka.clients.consumer.internals.AbstractCoordinator - > (Re-)joining group visits > [visits-bdb209f1-c9dd-404b-9233-064f2fb4227d-StreamThread-1] INFO > org.apache.kafka.clients.consumer.internals.AbstractCoordinator - > Successfully joined group visits with generation 974{code} > Any idea what could be going on? This service is only running with 2 > instances (each one stream thread). -- This message was sent by Atlassian JIRA (v7.6.3#76005)