采用 Doris的Routine Load直接消费Kafka中的日志和业务数据

本文主要是介绍采用 Doris的Routine Load直接消费Kafka中的日志和业务数据，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

创建主题

sh kafka-topics.sh --zookeeper vm01:2181,vm02:2181,vm03:2181 --create --topic track --partitions 3  --replication-factor 2

查看详细信息

sh kafka-topics.sh --zookeeper vm01:2181,vm02:2181,vm03:2181 --describe --topic track

查看偏移量

sh kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list vm01:9092,vm02:9092,vm03:9092 --topic track --time -1

创建生产者

 sh kafka-console-producer.sh --broker-list vm01:9092  --topic log_doris

创建消费者

sh kafka-console-consumer.sh --bootstrap-server vm01:9092 --topic log_doris

json

这篇关于采用 Doris的Routine Load直接消费Kafka中的日志和业务数据的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---