kafka批量删除topic_kafka查看topic数据量

kafka批量删除topic_kafka查看topic数据量利用kafka命令删除topic不成功。kafka-topics.sh–zookeeperhadoop111:2181–delete–topictest原因&解决方式1.配置文件未将delete.topic.enable=true,导致删除命令未及时生效;解决方式:第一种:找到conf目录下server.properties配置文件,修改delete.topic.enable=true,代表删除立即生效;[ssrs@hadoop111config]$pwd/opt/mod

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE稳定放心使用

前言: 利用kafka命令删除topic不成功。

kafka-topics.sh –zookeeper *.192.0.128:2181/kafka_yes –delete –topic test

原因&解决方式

  1. 配置文件未将delete.topic.enable=true,导致删除命令未及时生效;

解决方式:

第一种:找到conf目录下server.properties配置文件,修改delete.topic.enable=true,代表删除立即生效;

[root@node3a1 config]$ vi server.properties delete.topic.enable=true 修改配置后,需要重启kafka服务;
如果是cloudera 页面管理的kafka配置,需要点击delete.topic.enable 这个配置打对号

第二种:不修改delete.topic.enable=true配置文件的情况下,删除命令执行后,重启kafka服务,也可以使主题删除成功;

  1. 配置文件已经设置delete.topic.enable=true,删除命令执行后,还能看到topic名称;
    原因:生产者和消费者并未停止执行,导致虽然删除了topic,但是生产者或者消费者运行时,立刻重新创
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/181215.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • java中voliate的讲解

    java中voliate的讲解Java并发编程:volatile关键字解析  volatile这个关键字可能很多朋友都听说过,或许也都用过。在Java5之前,它是一个备受争议的关键字,因为在程序中使用它往往会导致出人意料的结果。在Java5之后,volatile关键字才得以重获生机。  volatile关键字虽然从字面上理解起来比较简单,但是要用好不是一件容易的事情。由于volatile关键字是与Java

  • SpringBoot启动报错:HikariPool-1 – Exception during pool initialization.

    SpringBoot启动报错:HikariPool-1 – Exception during pool initialization.2018-09-2516:16:16.264INFO15528—[main]com.zaxxer.hikari.HikariDataSource:HikariPool-1-Starting…TueSep2516:16:16CST2018WARN:EstablishingSSLconnectionwithoutserve…

  • 面向对象程序设计的基本原理_面向对象程序设计c++答案

    面向对象程序设计的基本原理_面向对象程序设计c++答案Java程序设计(面向对象)- 设计原理

  • 重庆java培训机构哪个好_java培训班

    重庆java培训机构哪个好_java培训班前言说到CAS(CompareAndSwap),不得不先说一说悲观锁和乐观锁,因为CAS是乐观锁思想的一种实现。悲观锁:总是很悲观的认为,每次拿数据都会有其他线程并发执行,所以每次都会进行加锁,用完之后释放锁,其他的线程才能拿到锁,进而拿到资源进行操作。java中的synchronized和ReentrantLock等独占锁就是悲观锁思想的实现。乐观锁:总是很乐观认为,自己拿到数据操作的时候,没有其他线程来并发操作,等自己操作结束要更新数据时,判断自己对数据操作的期间有没有其他线程进行操作,如果有,则

  • 布隆过滤器Bloom Filter简介

    布隆过滤器Bloom Filter简介

  • JDK卸载删除

    JDK卸载删除Java卸载1.进入环境变量,点击Java_Home2.进入路径,删除JDK清理环境变量删除path下关于Java的环境变量查看是否清除cdm运行输入java-version

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号