zookeeper删除kafka元数据,解决kafka无法消费数据的问题
2017-11-09 23:02
639 查看
启动kafka前没有启动zookeeper,导致消费者消费不到数据
解决方法:启动zookeeper的客户工具,删除zookeeper根目录下的brokers目录下的topic目录下的所有东西(这样会把之前建的所有topic都删除)
具体步骤:
1、启动zookeeper 客户端:进到zookeeper的安装目录
2、运行zkCli.sh
3、查看/brokers/topic下面有什么东西
4、删除里面所有的文件
解决方法:启动zookeeper的客户工具,删除zookeeper根目录下的brokers目录下的topic目录下的所有东西(这样会把之前建的所有topic都删除)
具体步骤:
1、启动zookeeper 客户端:进到zookeeper的安装目录
[root@Node1 bin]# cd /usr/apps/zookeeper/bin/
[root@Node1 bin]# ls README.txt zkCleanup.sh zkCli.cmd zkCli.sh zkEnv.cmd zkEnv.sh zkServer.cmd zkServer.sh zookeeper.out
2、运行zkCli.sh
[root@Node1 bin]# ./zkCli.sh Connecting to localhost:2181 2017-11-09 22:57:00,437 [myid:] - INFO [main:Environment@100] - Client environment:zookeeper.version=3.4.5-1392090, built on 09/30/2012 17:52 GMT 2017-11-09 22:57:00,453 [myid:] - INFO [main:Environment@100] - Client environment:host.name=Node1 2017-11-09 22:57:00,454 [myid:] - INFO [main:Environment@100] - Client environment:java.version=1.7.0_79 2017-11-09 22:57:00,454 [myid:] - INFO [main:Environment@100] - Client environment:java.vendor=Oracle Corporation 2017-11-09 22:57:00,458 [myid:] - INFO [main:Environment@100] - Client environment:java.home=/usr/java/jdk1.7/jre 2017-11-09 22:57:00,461 [myid:] - INFO [main:Environment@100] - Client environment:java.class.path=/usr/apps/zookeeper/bin/../build/classes:/usr/apps/zookeeper/bin/../build/lib/*.jar:/usr/apps/zookeeper/bin/../lib/slf4j-log4j12-1.6.1.jar:/usr/apps/zookeeper/bin/../lib/slf4j-api-1.6.1.jar:/usr/apps/zookeeper/bin/../lib/netty-3.2.2.Final.jar:/usr/apps/zookeeper/bin/../lib/log4j-1.2.15.jar:/usr/apps/zookeeper/bin/../lib/jline-0.9.94.jar:/usr/apps/zookeeper/bin/../zookeeper-3.4.5.jar:/usr/apps/zookeeper/bin/../src/java/lib/*.jar:/usr/apps/zookeeper/bin/../conf:.::/usr/java/jdk1.7/lib:/usr/java/jdk1.7/jre/lib 2017-11-09 22:57:00,462 [myid:] - INFO [main:Environment@100] - Client environment:java.library.path=/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib 2017-11-09 22:57:00,463 [myid:] - INFO [main:Environment@100] - Client environment:java.io.tmpdir=/tmp 2017-11-09 22:57:00,463 [myid:] - INFO [main:Environment@100] - Client environment:java.compiler=<NA> 2017-11-09 22:57:00,468 [myid:] - INFO [main:Environment@100] - Client environment:os.name=Linux 2017-11-09 22:57:00,469 [myid:] - INFO [main:Environment@100] - Client environment:os.arch=amd64 2017-11-09 22:57:00,470 [myid:] - INFO [main:Environment@100] - Client environment:os.version=2.6.32-573.el6.x86_64 2017-11-09 22:57:00,470 [myid:] - INFO [main:Environment@100] - Client environment:user.name=root 2017-11-09 22:57:00,471 [myid:] - INFO [main:Environment@100] - Client environment:user.home=/root 2017-11-09 22:57:00,471 [myid:] - INFO [main:Environment@100] - Client environment:user.dir=/usr/apps/zookeeper/bin 2017-11-09 22:57:00,477 [myid:] - INFO [main:ZooKeeper@438] - Initiating client connection, connectString=localhost:2181 sessionTimeout=30000 watcher=org.apache.zookeeper.ZooKeeperMain$MyWatcher@5409396f Welcome to ZooKeeper! 2017-11-09 22:57:00,533 [myid:] - INFO [main-SendThread(localhost:2181):ClientCnxn$SendThread@966] - Opening socket connection to server localhost/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error) 2017-11-09 22:57:00,550 [myid:] - INFO [main-SendThread(localhost:2181):ClientCnxn$SendThread@849] - Socket connection established to localhost/127.0.0.1:2181, initiating session JLine support is enabled 2017-11-09 22:57:00,565 [myid:] - INFO [main-SendThread(localhost:2181):ClientCnxn$SendThread@1207] - Session establishment complete on server localhost/127.0.0.1:2181, sessionid = 0x15fa12e114e0004, negotiated timeout = 30000 WATCHER:: WatchedEvent state:SyncConnected type:None path:null [zk: localhost:2181(CONNECTED) 0]
3、查看/brokers/topic下面有什么东西
[zk: localhost:2181(CONNECTED) 0] ls /brokers/topics
4、删除里面所有的文件
[zk: localhost:2181(CONNECTED) 0]rmr /brokers/topics/hive-test-table
相关文章推荐
- 解决kafka数据目录迁移后,flume无法正常调用Consumer的问题
- 解决kafka数据目录迁移后,flume无法正常调用Consumer的问题
- 解决kafka数据目录迁移后,flume无法正常调用Consumer的问题
- 解决kafka数据目录迁移后,flume无法正常调用Consumer的问题
- 解决kafka数据目录迁移后,flume无法正常调用Consumer的问题
- 解决kafka数据目录迁移后,flume无法正常调用Consumer的问题
- 解决kafka数据目录迁移后,flume无法正常调用Consumer的问题
- 解决kafka数据目录迁移后,flume无法正常调用Consumer的问题
- 解决kafka数据目录迁移后,flume无法正常调用Consumer的问题
- SharePoint2007:解决第二回收站大数据无法删除问题
- 解决kafka数据目录迁移后,flume无法正常调用Consumer的问题
- 解决kafka数据目录迁移后,flume无法正常调用Consumer的问题
- 解决kafka数据目录迁移后,flume无法正常调用Consumer的问题
- 解决kafka数据目录迁移后,flume无法正常调用Consumer的问题
- 解决kafka数据目录迁移后,flume无法正常调用Consumer的问题
- jQuery - 动态添加、删除form表单项(附:新增项数据无法提交问题解决)
- 解决kafka数据目录迁移后,flume无法正常调用Consumer的问题
- 解决kafka数据目录迁移后,flume无法正常调用Consumer的问题
- 如何解决使用addBatch()和executeBatch()无法批量增加删除修改数据库数据等问题
- 解决kafka数据目录迁移后,flume无法正常调用Consumer的问题