如何启用德鲁伊卡夫卡摄取？

Question

我正在关注 druid 文档，但在运行命令时

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

我得到了错误

Warning: Couldn't read data from file 
Warning: "quickstart/tutorial/wikipedia-kafka-supervisor.json", this 
makes an 
Warning: empty POST.

那么这个文件在哪里wikipedia-kafka-supervisor.json？

Answer 1

您可以在Github 上找到此文件的内容。

你需要先下载 Kafka：

curl -O https://archive.apache.org/dist/kafka/0.10.2.2/kafka_2.12-0.10.2.2.tgz
tar -xzf kafka_2.12-0.10.2.2.tgz
cd kafka_2.12-0.10.2.2

然后启动一个 Kafka 代理：

./bin/kafka-server-start.sh config/server.properties

并创建一个wikipedia 将数据发送到的主题：

./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic wikipedia

最后，您可以启动服务以启用 Druid Kafka 摄取：

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

如果supervisor创建成功，你会得到supervisor的ID作为响应；例如：

 {"id":"wikipedia-kafka"}