创建
 
创建kafka topic
 bin/kafka-topics.sh --create --topic topicname --replication-factor 1 --partitions 1 --zookeeper localhost:2181  


 方法一：
 执行linux命令：
 bin/kafka-topics.sh --create --topic topicname --replication-factor 1 --partitions 1 --zookeeper localhost:2181
 –topic指定topic name 
 –partitions指定分区数，这个参数需要根据broker数和数据量决定，正常情况下，每个broker上两个partition最好； 
 –replication-factor指定partition的replicas数，建议设置为2；


 方法二：
 开启自动创建配置：auto.create.topics.enable=true 
 使用程序直接往kafka中相应的topic发送数据，如果topic不存在就会按默认配置进行创建。

  
 
查看
 
bin/kafka-topics.sh --list --zookeeper localhost:2181

前些天发现了一个巨牛的人工智能学习网站，通俗易懂，风趣幽默，忍不住分享一下给大家。点击跳转到教程。
 
 
 
原因1：启动 broker 方式不对。
 
我完全是按照官方文档操作的，在网上看到说这一步是错误的启动 broker 方式！
 
nohup sh bin/mqbroker -n localhost:9876 &
 
改为：
 
nohup sh mqbroker -n localhost:9876 autoCreateTopicEnable=true &
 
 
 
原因2：未关闭防火墙。
 
原因2 转自：https://blog.csdn.net/chenaima1314/article/details/79403113
 
rocketmq运行时提示 No route info of this topic 异常产生的原因可能是
 
①Broker禁止自动创建Topic，且用户没有通过手工方式创建Topic
 
②Broker没有正确连接到Name Server
 ③Producer没有正确连接到Name Server 
 
首先解决①这种情况，启动顺序要先启动nameserver，再启动broker，启动broker时加上autoCreateTopicEnable=true 
 
例如 nohup sh mqbroker -n localhost:9876 autoCreateTopicEnable=true &
 
启动没有异常检查下nameserver中是否成功注册了broker，有两种方式 
 第一种、看broker的日志 如果出现形如
 2018-02-28 16:21:35 INFO BrokerControllerScheduledThread1 - register broker to name server 192.168.192.129:9876 OK
 2018-02-28 16:22:05 INFO BrokerControllerScheduledThread1 - register broker to name server 192.168.192.129:9876 OK
 证明已经连接到nameserver上
 第二种、 在bin目录下执行命令sh mqadmin clusterList -n localhost:9876 如果看到
 #Cluster Name     #Broker Name            #BID  #Addr                  #Version                #InTPS(LOAD)       #OutTPS(LOAD) #PCWait(ms) #Hour #SPACE
 DefaultCluster    DEFAULT_BROKER          0     192.168.192.129:10911  V4_2_0_SNAPSHOT          0.00(0,0ms)         0.00(0,0ms)          0 422168.55 -1.0000
 
也是证明已经连接到nameserver上。
 
如果按前两步检查没有问题，但启动还是报错，那么剩下的可能原因是producer无法连接到nameserver，很可能是防火墙的原因 ，要检验猜测只需要关闭防火墙，命令为systemctl stop firewalld.service
 然后再次验证，应该已经可以使用了。
 
 原因3.  少 jar 包：fastjson-1.2.29.jar  。
 
这是网上看到的，我的情况并不少这个jar 。
 
原因4. mqnameserver 或者 mqbroker 没有启动成功。
 
我的情况是 ：会报错内存不够。
 
报错为：
 
# There is insufficient memory for the Java Runtime Environment to continue.
# Native memory allocation (mmap) failed to map 805306368 bytes for committing reserved memory.
 
要在 /distribution/target/apache-rocketmq/bin 下的2个脚本中设置内存占用大小。
 
vim bin/runserver.sh　（调整nameserver启动的内存，不调整此文件，可能导致无法启动。）

JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn512m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"　

 vim bin/runbroker.sh     JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m"
 
 

两种方法：
 
 
 
一、修改配置文件server.properties
 
    添加如下配置：
 
        delete.topic.enable=true
 
 
 
说明：官方给的文档说明“Enables delete topic. Delete topic through the admin tool will have no effect if this config is turned off”，意思就是说如果想删除topic，此项配置必须为true，默认为false。配置完重启kafka、zookeeper。
 
 
 
二、如果不想修改配置，也可以彻底删除topic
 
 
 
1、删除kafka存储目录（server.propertiewenjian log.dirs配置，默认为“/tmp/kafka-logs”）下对应的topic。(不同broker下存储的topic不一定相同，所有broker都要看一下)
 
2、进入zookeeper客户端删掉对应topic
 
        zkCli.sh  -server 127.0.0.1:42182
 
   找到topic目录
 
        ls   /brokers/topics
 
   删掉对应topic
 
    rmr  /brokers/topic/topic-name
 
   找到目录
 
        ls    /config/topics
 
   删掉对应topic
 
        rmr  /config/topics/topic-name  
 
 
 
以上两步全部执行才算彻底删除topic
 
 
 
 
 
---
更多文章关注公众号

截图事例：
 先查看topic：
 
 HelloWor、HelloWorld、test。这三个是我之前创建的。
 我想删掉HelloWor。结果出现错误。
 报错如下：
 
 解决：topic名字打错了，导致zk找不到对应的topic。