Kafka的java api 操作(一)

1、创建java的maven工程 2、引入依赖     3、编写测试类 package com.motoon; import kafka.admin.AdminUtils; import kafka.admin.RackAwareMode; import kafka.server.ConfigType; import kafka.utils.ZkUtils; import org.apache.
相关文章
相关标签/搜索