我对hive/hadoop比较陌生我正在阅读这个HiveStorageHandlers.现在我正在尝试编写HiveStorageHandler的自定义实现，以使用Hive表查询消息并将消息推送到Kafka。我看到还有HiveStorageHandler的其他实现，它允许我们使用配置单元表在NoSQL数据库上查询和写入。我正在尝试为Kafka复制它。我在上面找到了一个项目HiveKa-queryKafkausingHive在这里，他们试图使用配置单元表上的查询从Kafka读取数据。我希望使用insertonthetable来写关于kafka的话题。有人可以指导我吗？