数据存储在名为sample_data（KAFKA）的主题中。

我用过：

consumer = kafka.KafkaConsumer(bootstrap_servers=server,security_protocol='SASL_SSL',sasl_mechanism = 'PLAIN',sasl_plain_username = API_KEY,sasl_plain_password = API_SECRET)

现在的消费者是。

但是文件已锁定，我需要将其解锁。您能给我任何提示吗？任务是：

“解锁数据预测主题。 消耗sample_data主题中的所有消息，并向我们提供消息总数。“

我尝试过：

for c in consumer:
    print('test')

但是代码只是计算，甚至没有启动。因此我决定，问题出在“锁定数据”。如何解锁？