topic creation

[adyliu]

We need the function of topic creation.

Sending messages to the broker first time, we need to create the topic with given partition.

Though this operation can be finished in the broker configuration. But this need restarting.

This tools can enlarge the partition of exist topic also.

[adyliu]

added in v1.2.0 Link

admin-console.sh:

Create/Delete Topic
Usage: -c -h <host> -p <port> -t <topic> -P <partition> [-e]
       -d -h <host> -p <port> -t <topic> --password <password>
Option                                  Description                            
------                                  -----------                            
-P, --partition [Integer: partition]    topic partition (default: 1)           
-c, --create                            create topic                           
-d, --delete                            delete topic                           
-e, --enlarge                           enlarge partition number if exists     
-h, --host <host>                       server address                         
-p, --port <Integer: port>              server port                            
--password [password]                   jafka password                         
-t, --topic <topic>                     topic name               

[linyuan123]

为什么 我执行删除命令 发现topic 没有被删除掉啊

[adyliu]

哪个版本？ 命令行参数是啥？

[linyuan123]

在 maven 中央仓库下载的最新版本1.6.1 的 命令行参数

[root@master bin]# ./admin-console.sh -d -h 192.168.1.101 -p 9092 -t ssss --password plain:jafka
delete -1 partitions for topic [ssss]

[linyuan123]

还想问下 jafka 集群怎么搭建啊 我现在搭建的是单机版 ，网上关于jafka 的资料太少了

[adyliu]

sh /opt/apps/jafka/bin/admin-console.sh -d -h 127.0.0.1 -p 9092 -t demo --password jafka

我刚操作过，删除没问题。 密码没有plain: 前缀

[adyliu]

集群搭建非常简单，
服务端(broker): 修改配置 server.conf中 enable.zookeeper/zk.connect 即可。
客户端(client):使用zookeeper配置即可。

可以参考：

1. https://github.com/adyliu/jafka/wiki/quickstart.zh_CN
2. https://gist.github.com/adyliu/5674c683ba2737e136d8