Open
Description
For KafkaConsumer.subscribe()
either topics
or pattern
must be specified but not both. While experimenting, I noticed that when I break this contract, I get an AssertionError
.
Since this is caused by bad input, and not bad code, this should throw ValueError
not AssertionError
.
Assertions will get stripped out if python is run with the optimized flag, removing the safety net of this check. While rare in dev, some places do run python this way in production.
Happy to put together a PR if you want, but wanted to doublecheck you're on board with this change.