Minor 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
- links to
