当数据发送到 Kafka 后,Druid 应该能够马上查询到导入的数据的。
请访问 query tutorial 页面中的内容来了解如何针对新导入的数据运行一些查询。
如果你希望其他的一些入门教程的话,你需要首先关闭 Druid 集群;删除 var
目录中的所有内容;再重新启动 Druid 集群。
这是因为本教程中其他的导入数据方式也会写入相同的 “wikipedia” 数据源,如果你使用不同的数据源的话就不需要进行清理了。
同时你可能也希望清理掉 Kafka 中的数据。你可以通过 CTRL-C 来关闭 Kafka 的进程。在关闭 Kafka 进程之前,请不要关闭 ZooKeeper 和 Druid 服务。
然后删除 Kafka 的 log 目录/tmp/kafka-logs
:
rm -rf /tmp/kafka-logs
https://www.ossez.com/t/druid-kafka/13657#heading-1