当前位置: 首页 > 知识库问答 >
问题:

测试是否正确设置了Kafka主题

顾乐池
2023-03-14

我们的应用程序使用各种类型的队列。每次在启动使用队列的应用程序之前,都会进行一次自动预检查,将示例消息写入所需队列并读取(即删除)它,以确认队列设置是否正确。

现在我们也用Kafka。但是在Kafka中,我们不能通过写和读带有主题的消息来进行预检查,因为在启动实际应用程序之前不能删除这些消息,这会“污染”主题。在Kafka中是否有其他自动化的方法,API或命令行脚本来实现这一点?最好使用java或shell脚本。

Kafka版本0.11.x

共有1个答案

武向文
2023-03-14

kafka-topics--description--topic your_topic--zookeeper your_zk就足够了。如果有与活动副本同步的输出,你应该很好地去。如果内置工具不能提供您所需要的(即您不能/不想访问ZooKeeper),那么另一种工具是kafkacat。

 类似资料:
  • 问题内容: Java和Mac都相当新。我想确保已设置JAVA_HOME,以便在其他程序中可以使用其路径。所以我做了一些谷歌搜索,这就是我得到的: 如果我在终端中输入 / usr / libexec / java_home ,则得到此信息: /System/Library/Java/JavaVirtualMachines/1.6.0.jdk/Contents/Home 但如果在终端中输入 echo

  • 对Java和Mac都很陌生...我想确定JAVA_HOME的设置,以便在其他程序中可以使用它的路径。所以我在谷歌上搜索了一下,下面是我得到的信息: 如果我在terminal中输入/usr/libexec/java_home,我会得到/system/library/java/javavirtualmachines/1.6.0.jdk/contents/home,但是如果我在terminal中输入ec

  • 因为我编码C已经超过20年了,我想我是时候参加一次测试了!看看我是不是学到了什么,或者我只是在网上给初学者发免费但不正确的建议。 这个网站(我不是附属)提供免费的C测试。https://www.tutorialspoint.com/cprogramming/cprogramming_mock_test.htm。

  • 使用Fork-Join框架的资源,创建一个同步多线程系统,从三个文本文件中形成一个最大长度的单词集合。不要使用中间集合来读取文本。在本例中,工作由存储在MaxLengthWord类的arr字段中的数组表示。createSubtasks()方法递归地将任务分成更小的工作部分,直到每个工作部分都小于阈值。

  • Kafka再平衡算法是否适用于不同主题? 假设我有5个主题,每个主题都有10个分区,同一消费者组中有20个消费者应用程序实例,每个实例都订阅了这5个主题。 Kafka会尝试在20个实例中平衡50个分区吗? 还是它只在一个主题内保持平衡,因此10个第一个实例可能(或可能)接收所有50个分区,而其他10个实例可能保持空闲? 我知道,在过去,Kafka并没有在不同的主题之间取得平衡,但现在的版本呢?

  • 我的页面上有两个按钮,一个用于查看pdf(在新选项卡中打开),一个用于下载pdf(通过添加附件标题直接下载)。 以下是我到目前为止的测试代码: