Skip to content
This repository has been archived by the owner on Jan 24, 2024. It is now read-only.

Fix deadlock caused by KafkaTopicConsumerManager #620

Merged
merged 3 commits into from
Jul 23, 2021
Merged

Fix deadlock caused by KafkaTopicConsumerManager #620

merged 3 commits into from
Jul 23, 2021

Commits on Jul 22, 2021

  1. Run a single cursor expire task instead one task per channel

    @BewareMyPower
    BewareMyPower committed Jul 22, 2021
    Configuration menu
    Copy the full SHA
    7cf69c5 View commit details
    Browse the repository at this point in the history

  2. Use AtomicBoolean as KafkaTopicConsumerManager's state

    @BewareMyPower
    BewareMyPower committed Jul 22, 2021
    Configuration menu
    Copy the full SHA
    968c24e View commit details
    Browse the repository at this point in the history

  3. Use ConcurrentHashMap to replace ConcurrentLongHashMap

    @BewareMyPower
    BewareMyPower committed Jul 22, 2021
    Configuration menu
    Copy the full SHA
    cfb2721 View commit details
    Browse the repository at this point in the history