问题描述
数据存储在名为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')
但是代码只是计算，甚至没有启动。因此我决定，问题出在“锁定数据”。如何解锁？
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）