本文主要是介绍采用 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中的日志和业务数据的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
