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

KafkaConsumer should validate topics/TopicPartitions on subscribe/assign

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Minor
    • Resolution: Won't Do
    • Affects Version/s: 0.11.0.0
    • Fix Version/s: 1.1.0
    • Component/s: clients
    • Labels:
      None

      Description

      Currently, KafkaConsumer checks if the provided topics on subscribe() and TopicPartition on assign() don't contain topic names that are null or an empty string.

      However, it could do some more validation:

      • check if invalid topic characters are in the string (this might be feasible for {Patterns}}, too?)
      • check if provided partition numbers are valid (ie, not negative and maybe not larger than the available partitions?)

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                vahid Vahid Hashemian
                Reporter:
                mjsax Matthias J. Sax
              • Votes:
                0 Vote for this issue
                Watchers:
                5 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: