Kafka
  1. Kafka
  2. KAFKA-197

Embedded consumer doesn't shut down if the server can't start

    Details

    • Type: Bug Bug
    • Status: Resolved
    • Priority: Major Major
    • Resolution: Fixed
    • Affects Version/s: 0.7
    • Fix Version/s: 0.7.1
    • Component/s: None
    • Labels:
      None

      Description

      If a broker embeds a consumer and the broker itself doesn't start (e.g., conflicting broker id in ZK), the embedded consumer is still running. In this case, we should probably shut down the embedded consumer too.

      To do this, we need to either throw an exception or return an error in KafkaServer.startup and act accordingly in KafkaServerStartable.startup.

      1. KAFKA-197_v2.patch
        6 kB
        Jun Rao
      2. KAFKA-197.patch
        0.4 kB
        Jun Rao

        Activity

        Jun Rao created issue -
        Jun Rao made changes -
        Field Original Value New Value
        Attachment KAFKA-197.patch [ 12505942 ]
        Jun Rao made changes -
        Status Open [ 1 ] Patch Available [ 10002 ]
        Fix Version/s 0.7.1 [ 12319140 ]
        Jun Rao made changes -
        Attachment KAFKA-197_v2.patch [ 12506138 ]
        Jun Rao made changes -
        Status Patch Available [ 10002 ] Resolved [ 5 ]
        Assignee Jun Rao [ junrao ]
        Resolution Fixed [ 1 ]

          People

          • Assignee:
            Jun Rao
            Reporter:
            Jun Rao
          • Votes:
            0 Vote for this issue
            Watchers:
            0 Start watching this issue

            Dates

            • Created:
              Updated:
              Resolved:

              Development