我需要删除kafka-0.8.2.2.3中的主题.我使用以下命令删除主题:
bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic DummyTopic
该命令执行成功,但是当我运行命令列出主题时,我可以看到该主题仍然存在,并显示标记为删除.
bin/kafka-topics.sh --list --zookeeper localhost:2181
DummyTopic - marked for deletion
当我创建DummyTopic主题时,它会输出异常,主题已经存在,下面是堆栈跟踪:
Error while executing topic command Topic "DummyTopic" already exists.
kafka.common.TopicExistsException: Topic "DummyTopic" already exists.
at kafka.admin.AdminUtils$.createOrUpdateTopicPartitionAssignmentPathInZK(AdminUtils.scala:248)
at kafka.admin.AdminUtils$.createTopic(AdminUtils.scala:233)
at kafka.admin.TopicCommand$.createTopic(TopicCommand.scala:92)
at kafka.admin.TopicCommand$.main(TopicCommand.scala:54)
at kafka.admin.TopicCommand.main(TopicCommand.scala)
请让我知道如何删除此主题.
我想通过java代码生成线程转储,我尝试使用ThreadMXBean,但我没有得到正确格式的线程转储,因为我们正在使用jstack命令.请任何人提供一些帮助..是他们的任何其他方式来获取线程转储...使用任何其他API ..我想要的线程转储的格式是 -
2015-08-06 05:51:15
Full thread dump Java HotSpot(TM) 64-Bit Server VM (24.51-b03 mixed mode):
"Attach Listener" daemon prio=10 tid=0x00007fdab805d800 nid=0x7a36 waiting on condition [0x0000000000000000]
java.lang.Thread.State: RUNNABLE
"ajp-mco/127.168.121.120:8170-220" daemon prio=10 tid=0x00007fdaa056d000 nid=0x7961 runnable [0x00007fda8bb7a000]
java.lang.Thread.State: RUNNABLE
at java.net.SocketInputStream.socketRead0(Native Method)
at java.net.SocketInputStream.read(SocketInputStream.java:152)
at java.net.SocketInputStream.read(SocketInputStream.java:122)
at org.apache.coyote.ajp.AjpProcessor.read(AjpProcessor.java:1114)
at org.apache.coyote.ajp.AjpProcessor.readMessage(AjpProcessor.java:1196)
at org.apache.coyote.ajp.AjpProcessor.process(AjpProcessor.java:436)
at org.apache.coyote.ajp.AjpProtocol$AjpConnectionHandler.process(AjpProtocol.java:420)
at org.apache.tomcat.util.net.JIoEndpoint$Worker.run(JIoEndpoint.java:920)
at java.lang.Thread.run(Thread.java:744)
我写了一个Junit测试来测试我的代码.当我的代码中出现任何异常时,我希望我的Junit测试用例失败.我尝试使用assert语句,但即使我的代码中出现异常,我的Junit测试用例也正在通过.请有人能告诉我如何实现这一目标吗？谢谢.
我正在编写一个 shell 脚本，它使用 scp 命令将文件从一台服务器复制到另一台服务器。但是每次由于 scp 命令而在命令行中运行脚本时，它都会要求输入密码。我不想从命令行传递密码，因为它们在脚本中大约有 36 个 scp 命令，用于从这么多服务器传输文件。所以我想要一种合适的方式来只从我的 shell 脚本传递密码。有人可以帮我通过脚本传递 scp 命令的密码......谢谢......
下面是我在我的 shell 脚本中使用的 scp 命令----`
scp -r root@$source_host:/$source_path root@$destination_host:/$destination_path
请有人可以帮助我.....谢谢。