You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Ryanne Dolan (JIRA)" <ji...@apache.org> on 2018/10/05 19:32:00 UTC
[jira] [Resolved] (KAFKA-6990) CommitFailedException; this task may
be no longer owned by the thread
[ 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)