kafka删除topic

相关文章

• 

  kafka通过命令行删除指定topic下所有records

   1、kafka环境配置  由于在windows环境下，在kafka官网下载下来Apache Kafka需要将E:kafka_2.12-3.3.1binwindows下的路径加入到环境变量中，方便直接使用kafka工具，其他系统直接使用bin下的工具即可： 2、配置kafka指定topic的json文件，命名为delete.json，此文件放在任意位置都可： 可以查

  2024年02月14日

  浏览(30)

• 02-Kafka之server.properties核心配置详解

  一、Broker相关配置 二、Topic相关配置 三、zookeeper相关配置 四、日志相关配置

  2024年02月16日

  浏览(22)
• 

  kafka 基础概念、命令行操作（查看所有topic、创建topic、删除topic、查看某个Topic的详情、修改分区数、发送消息、消费消息、 查看消费者组 、更新消费者的偏移位置）

  kafka官网 Broker   一台kafka服务器就是一个broker，可容纳多个topic。一个集群由多个broker组成； Producer   生产者，即向kafka的broker-list发送消息的客户端； Consumer   消费者，即向kafka的broker-list订阅消息的客户端； Consumer Group   消费者组是 逻辑上的一个订阅者 ，由多个

  2024年02月01日

  浏览(40)

• kafka topic和topic权限操作

  创建 查询 删除 增加 移除 查询

  2024年02月12日

  浏览(27)
• 

  Kafka/Spark-01消费topic到写出到topic

  消费者代码 注意点 consumerConfigs是定义的可变的map的类型的，具体如下 consumerConfigs.put(ConsumerConfig.GROUP_ID_CONFIG , groupId)是为了不限制groupId特意写的传参 是使用自带的kafka工具类createDirectStream方法去消费kafak 的数据，详细参数解释如下 Subscribe传参需要指定泛型，这边指定string，

  2024年02月09日

  浏览(26)

• 解决No spring.config.import property has been defined，学习笔记三

  在学习Nacos组件，加载多配置集时遇到问题，希望微服务在读取配置文件之前先去nacos中读取配置文件优先于本地配置。配置了 bootstrap.properties 后启动项目报错： 后续找解决方案发现是因为在springcloud 2020.0.2版本中把bootstrap的相关依赖从spring-cloud-starter-config中移除了，所以现

  2024年01月16日

  浏览(23)

• Kafka 清空Topic

  测试环境某topic的数据格式发生了更改，需要将原有数据清空重新生产数据。 还需检查当前kafka topic对应的分区副本（假定单分区单副本）大小，用于验证数据是否已删除。 将过期时间设置为1秒 直到该文件夹显示大小是20K即证明数据已清理 同时需注意，数据清理时机受ser

  2024年01月16日

  浏览(33)

• 记录一次SpringBoot3+Nacos Config做配置中心时，No spring.config.import property has been defined的问题

  以下为报错信息： No spring.config.import property has been defined 启动时,控制台已经很明确的给出了一个标准的解决方案： Add a spring.config.import=nacos: property to your configuration. If configuration is not required add spring.config.import=optional:nacos: instead. To disable this check, set spring.cloud.nacos.config.import

  2024年02月11日

  浏览(40)

• springboot整合Nacos配置中心报错create config service error!properties=Nacos

  描述：最近在整合谷粒商城项目的过程中发现一个问题， create config service error!properties=NacosConfigProperties{serverAddr=\\\'null\\\', encode=\\\'null\\\', group=\\\'DEFAULT_GROUP\\\', prefix=\\\'null\\\', fileExtension=\\\'properties\\\', timeout=3000, endpoint=\\\'null\\\', namespace=\\\'null\\\', accessKey=\\\'null\\\', secretKey=\\\'null\\\', contextPath=\\\'null\\\', clusterName=\\\'null\\\'

  2024年02月14日

  浏览(25)
• 

  Flink实现同时消费多个kafka topic，并输出到多个topic

  1）代码使用的 flink版本为1.16.1 ，旧版本的依赖及api可能不同，同时使用了hutool的JSON工具类，两者均可自行更换； 2）本次编写的两个方案，均只适用于 数据源topic来自同一个集群 ，且kafka消费组相同，暂未研究flink的connect算子join多条流 代码涉及 Hadoop相关环境 ，若无该环境

  2023年04月20日

  浏览(65)