Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-351 Refactor some new components introduced for replication
  3. KAFKA-356

Create a generic Kafka thread class that includes basic boiler plate code of instantiating and shutting down threads cleanly

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Closed
    • Major
    • Resolution: Fixed
    • 0.8.0
    • 0.8.0
    • None

    Description

      We have a lot of threads that basically run in a loop and use an isRunning atomic boolean and count down latch. It will be useful to refactor it out into a helper runnable that these can extend. Verifying the lifecycle details for each is kind of a pain and it pretty easy to either not cleanly shutdown all the threads.

      Attachments

        1. kafka_356_v6.diff
          29 kB
          Yang Ye
        2. kafka_356_v5.diff
          30 kB
          Yang Ye
        3. kafka_356_v4.diff
          27 kB
          Yang Ye
        4. kafka_356_v3.diff
          30 kB
          Yang Ye
        5. kafka_356_v2.diff
          19 kB
          Yang Ye
        6. kafka_356_v1.diff
          17 kB
          Yang Ye

        Activity

          People

            yeyangever Yang Ye
            nehanarkhede Neha Narkhede
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: