Kafka官方提供了两个脚本来管理topic，包括topic的增删改查。其中kafka-topics.sh负责topic的创建与删除；kafka-configs.sh脚本负责topic的修改和查询，但很多用户都更加倾向于使用程序API的方式对topic进行操作 ...

1.pom 　　<dependency> 　　　　<groupId>org.apache.kafka</groupId> 　　　　<artifactId>kafka_2.10</artifactId> 　　　　< ...

　　前段时间在Kafka QQ群中有人问及此事——关于Java consumer如何动态修改topic订阅的问题。仔细一想才发现这的确是个好问题，因为如果简单地在另一个线程中直接持有consumer实例然后调用subscribe进行修改，consumer端必然会抛出异常 ...

前言 利用kafka命令删除topic不成功。 原因&解决方式 1. 配置文件未将delete.topic.enable=true，导致删除命令未及时生效； 解决方式： 第一种： 找到conf目录下server.properties配置文件，修改 ...

一、Topic管理 1、创建topic 2、新增partition 注：topic一旦创建，partition只能增加，不能减少 3、删除topic 4、查看topic列表 5、查看topic详细信息 6、查看 ...

手动： 删除kafka存储目录（server.properties文件log.dirs配置，默认为"/tmp/kafka-logs"）相关topic目录 删除zookeeper "/brokers/topics/"目录下相关topic节点 命令+手动 ...

概述 　　在平时对kafka的运维工作中，我们经常会由于某些原因去删除一个topic，比如这个topic是测试用的，生产环境中需要删除。或者我想扩容topic的同时，这个topic中的数据我不想要了，这时候删除topic，增加broker，再重新创建topic就会是比较简单的方法。但是kafka ...

执行 windows 脚本 命令行程序，获取 broker 元数据，计算副本分配方案，然后把 topic 的信息写入 zk KafkaController 监听 zk 节点的变化，并产生 TopicChange 事件 ...