Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-495

Handle topic names with "/" on Kafka server

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Major
    • Resolution: Fixed
    • 0.7, 0.8.0
    • 0.7.2, 0.8.0
    • None

    Description

      If a producer publishes data to topic "foo/foo", the Kafka server ends up creating an invalid directory structure on the server. This corrupts the zookeeper data structure for the topic - /brokers/topics/foo/foo. This leads to rebalancing failures on the consumer as well as errors on the zookeeper based producer.

      We need to harden the invalid topic handling on the Kafka server side to avoid this.

      Attachments

        1. kafka-495-v1.patch
          4 kB
          Swapnil Ghike
        2. kafka-495-v2.patch
          6 kB
          Swapnil Ghike
        3. kafka-495-v3.patch
          6 kB
          Swapnil Ghike
        4. kafka-495-v4.patch
          6 kB
          Swapnil Ghike
        5. kafka-495-v0.8.patch
          7 kB
          Swapnil Ghike
        6. kafka-495-v0.8-v2.patch
          33 kB
          Swapnil Ghike
        7. kafka-495-v0.8-v3.patch
          13 kB
          Swapnil Ghike
        8. kafka-v0.8-v4.patch
          9 kB
          Swapnil Ghike

        Activity

          People

            swapnilghike Swapnil Ghike
            nehanarkhede Neha Narkhede
            Votes:
            0 Vote for this issue
            Watchers:
            6 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: