小编Lil*_*yAZ的帖子

正如标题中所说，我想在我的主题中获得一些记录，但我找不到使用 kafka-python 库的解决方案。有人有什么主意吗 ？

我正在使用该printSchema函数来推断 Json 文件的架构。我想将此函数调用的结果保存在一个变量中，以便逐行解析它，以便我可以提取模式结构并将其转换为 DDL 模式，以便在 hive 中创建表。

如何才能做到这一点？

我想将一个主题的默认保留时间更改为“rentention.ms=100”，但我在 python 中找不到解决方案。有人可以帮我吗，拜托？