I get an inspection warning in PyCharm "if a protected member is accessed outside the class where it's defined or in a module." I import TopicPartition in order to be able to create TopicPartition objects for assignment to the consumer.
The following change in __init__ in the kafka directory remedies this situation.[cid:[email protected]] Daniel Keefe Distinguished Member Technical Staff Dell EMC | Integrated Offerings
