使用Shell客户端操作kafka

2018-10-04|来源:

master上创建一个test1主题

/opt/kafka/kafka_2.10-0.9.0.1/bin/kafka-topics.sh --create --topic test1 --replication-factor 3 --partitions 2 --zookeeper master:2181


replication-factor的几个不能超过Kafkar集群的broker数据

Error while executing topic command : replication factor: 3 larger than available brokers: 2

[2016-09-25 07:56:34,226] ERROR kafka.admin.AdminOperationException: replication factor: 3 larger than available brokers: 2


master上查看刚才创建的test1主题

bin/kafka-topics.sh --list --zookeeper master:2181

test1


zkCli上查看主题

[zk: localhost:2181(CONNECTED) 16] ls /brokers/topics

[test1]


slave1上发送消息至kafka,发送消息hello kafka

bin/kafka-console-producer.sh --broker-list master:9092,slave1:9092,slave2:9092 --sync --topic test1

hello kafka


master上开启一个消费者,可以看到刚才发送的消息

[hadoop@master kafka_2.10-0.9.0.1]$ bin/kafka-console-consumer.sh --zookeeper master:2181 --topic test1 --from-beginning

hello kafka


删除掉一个Topic

bin/kafka-topics.sh --delete --topic test1 --zookeeper master:2181

Topic test1 is marked for deletion.

Note: This will have no impact if delete.topic.enable is not set to true.

这条命令其实并不执行删除动作,仅仅是在zookeeper上标记该topic要被删除而已,同时也提醒用户一定要提前打开delete.topic.enable开关,否则删除动作是不会执行的


同时zookeeper(假设你的chroot就是/)的/admin/delete_topics下创建一个临时节点,名字就是topic名称

[zk: localhost:2181(CONNECTED) 21] ls /admin/delete_topics

[test1]

[zk: localhost:2181(CONNECTED) 22] ls /brokers/topics    

[test1]

在server.properties中设置delete.topic.enable=true,重启kafka就删除了


相关问答

更多

fastdfs Java客户端使用

API(Application Programming Interface,应用程序编程接口)是一些预先定义的函数,目的是提供应用程序与开发人员基于某软件或硬件的以访问一组例程的能力,而又无需访问源码,或理解内部工作机制的细节。 Windows API是一套用来控制Windows的

GPRS客户端与JAVA服务端通信问题

现在还需要答案吗?我现在是两个互相发信息都可以 要是你还没解决的话可以找我 但是我想问下你那个客户端使用GPRS网络该怎么弄呢 429161502 谢谢

我想开发一个客户端软件。应该怎么做

通讯软件分为客户端和服务器(C/S),各个项目(C/S)独立进行开发,是通过SOCKET从服务器获取数据,当客户端(比如按钮)发生事件时,将这个事件的数据通过SOCKET方式发送到服务器,然后服务器处理这个事件,回复给客户端

java socket如何实现客户端与客户端的交互?

给你一个思路: 1、服务端监听一个端口,其它客户端都通过这个端口和服务端进行通信。 2、每个客户端连接上来,服务端给其一个标识ID。然后向其它所有客户端广播一下有新客户端接入,ID多少。 3、客户端要向客户端发送消息,可以以消息包的形式发送,就是把目的客户端的标识和发送的内容组成一个数据包发往服务器,服务器读取就知道要向哪 个客户端发送数据,然后把内容往目的客户端通道发送

如何运行与使用OpenVAS客户端

一旦扫描器守护进程开始运行,您就可以启动一个客户端并连接到该扫描器。我们已经在作为扫描器的同一个主机上安装了客户端,但其实您也可以在任何想要的主机上安装客户端,并远程连接到扫描器。现在,我们运行该客户端: $ OpenVAS-Client 这样

kafka分布式消息队列

相关文章

更多

最近更新

更多