消息队列MQ

Druid 加载 Kafka 数据时直接提交一个 supervisor

本文主要是介绍Druid 加载 Kafka 数据时直接提交一个 supervisor，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！

为了能够直接启动一个服务，我们需要提交一个 supervisor 配置参数到 Druid overlord 进程中，你可以直接通过 Druid 的包运行下面的命令：

curl -XPOST -H'Content-Type: application/json' -d @quickstart/tutorial/wikipedia-kafka-supervisor.json http://localhost:8081/druid/indexer/v1/supervisor

 

2021-08-06_14-52-23

 

如果提交的 supervisor 被成功创建的话，在返回的结果中将会有一个创建的 supervisor ID；在我们当前的示例中，你应该可以看到返回的结果为 {"id":"wikipedia"}。

如果想了解更多有关 Kafka 的数据导入相关的信息，请参考 Druid Kafka indexing service documentation 页面中的内容。

你也可以从 Druid 的控制台中查看当前的 supervisors 和任务。针对本地服务器的访问地址为： http://localhost:8888/unified-console.html#tasks 。

https://www.ossez.com/t/druid-kafka-supervisor/13656

 

这篇关于Druid 加载 Kafka 数据时直接提交一个 supervisor的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！
您可能喜欢
栏目导航