如何订阅apache kafka主题并将主题数据流到蜂巢表?
Kafka主题将实时更新。
做到这一点的最佳方法是使用Kafka Connect和HDFS连接器。这是一个快速入门,向您展示了如何使用它。
使用kafkaconnect的HDFS连接器。
所有配置属性和常见示例都可以在https://docs.confluent.io/current/current/connect/kafka-connect-hdfs/configuration_options.html#hive
对于示例配置,您可以查看问题中发布的配置:Kafka Connect-带有HDFS接收器连接器的提取物转换抛出NullPoInterException
您可以使用上面指定的HDFS连接器使用kafka Connect接收器,并使用该特定HDFS位置的HIVE创建外部表。