kafka入门2:java 创建及删除 topic

1.pom

   <dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka_2.10</artifactId>
    <version>0.10.2.1</version>
  </dependency>
  <dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-clients</artifactId>
    <version>0.10.2.1</version>
  </dependency>

2.KafkaTopicBean

public class KafkaTopicBean {

    private String topicName;       // topic 名称
private Integer partition; // partition 分区数量
private Integer replication; // replication 副本数量
private String descrbe; public String getTopicName() {
return topicName;
} public void setTopicName(String topicName) {
this.topicName = topicName;
} public Integer getPartition() {
return partition;
} public void setPartition(Integer partition) {
this.partition = partition;
} public Integer getReplication() {
return replication;
} public void setReplication(Integer replication) {
this.replication = replication;
} public String getDescrbe() {
return descrbe;
} public void setDescrbe(String descrbe) {
this.descrbe = descrbe;
} @Override
public String toString() {
return "KafkaTopicBean [topicName=" + topicName + ", partition=" + partition
+ ", replication=" + replication + ", descrbe=" + descrbe +"]";
} }

3.KafkaUtil

import java.util.Properties;
import org.apache.kafka.common.security.JaasUtils;
import kafka.admin.AdminUtils;
import kafka.admin.RackAwareMode;
import kafka.utils.ZkUtils; public class KafkaUtil { public static void createKafaTopic(String ZkStr,KafkaTopicBean topic) {
ZkUtils zkUtils = ZkUtils.
apply(ZkStr, 30000, 30000,JaasUtils.isZkSecurityEnabled()); AdminUtils.createTopic(zkUtils, topic.getTopicName(), topic.getPartition(),
topic.getReplication(), new Properties(), new RackAwareMode.Enforced$());
zkUtils.close();
} public static void deleteKafaTopic(String ZkStr,KafkaTopicBean topic) {
ZkUtils zkUtils = ZkUtils.
apply(ZkStr, 30000, 30000,JaasUtils.isZkSecurityEnabled()); AdminUtils.deleteTopic(zkUtils, topic.getTopicName());
zkUtils.close();
} }

4.调用方式

    public static void main(String[] args) {

        //zookeeper地址:端口号
String ZkStr = "912.168.0.1:2181"; //topic对象
KafkaTopicBean topic = new KafkaTopicBean();
topic.setTopicName("testTopic"); //topic名称
topic.setPartition(1); //分区数量设置为1
topic.setReplication(1);  //副本数量设置为1 //创建topic
KafkaUtil.createKafaTopic(ZkStr,topic);
//删除topic
KafkaUtil.deleteKafaTopic(ZkStr,topic); }

文章来源地址https://www.yii666.com/article/758068.html文章地址https://www.yii666.com/article/758068.html网址:yii666.com<网址:yii666.com文章来源地址:https://www.yii666.com/article/758068.html

版权声明:本文内容来源于网络,版权归原作者所有,此博客不拥有其著作权,亦不承担相应法律责任。文本页已经标记具体来源原文地址,请点击原文查看来源网址,站内文章以及资源内容站长不承诺其正确性,如侵犯了您的权益,请联系站长如有侵权请联系站长,将立刻删除

kafka入门2:java 创建及删除 topic-相关文章

  1. kafka入门2:java 创建及删除 topic

  2. kafka删除topic及其相关数据

  3. kafka删除topic详解

  4. kafka 删除topic

  5. kafka删除topic

  6. kafka删除一个topic

  7. Kafka如何彻底删除topic及数据

  8. Kafka Java API操作topic

    Kafka官方提供了两个脚本来管理topic,包括topic的增删改查。其中kafka-topics.sh负责topic的创建与删除;kafka-configs.sh脚本负责topic的修改和查询,但很多用户都更加倾向于使用程序API的方式对topic进行操作。 上一篇文章中提到了如何使用客户端协议(client protocol)来创建topic,本文则

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

微信图片_20190322181744_03.jpg

微信扫一扫打赏

请作者喝杯咖啡吧~

支付宝扫一扫领取红包,优惠每天领

二维码1

zhifubaohongbao.png

二维码2

zhifubaohongbao2.png