如何使DruidKafka摄取?

8wigbo56  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(173)

我正在遵循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 ?

pengsaosao

pengsaosao1#

您可以在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

如果成功创建了主管,您将获得主管的id作为响应;例如:

{"id":"wikipedia-kafka"}

相关问题