撰写于    浏览:628 次  分类: kafka研究
只有旧版本的消费者客户端才支持删除群组的操作。删除群组操作将从Zookeeper上移除整个群组,包括所有已保存的偏移量。在执行该操作之前,必须关闭所有的消费者。如果不先执行这一步,可能会导致消费者出现不可预测的行为,因为群组的元数据已经从Zookeeper上移除了。示例:删除消费者群组testgroupkafka-consumer-groups.s[...]

撰写于    浏览:651 次  分类: kafka研究
在Kafka里,有两个地方保存着消费者群组的信息。对于旧版本的消费者来说,它们的信息保存在Zookeeper上,对于新版本的消费者来说,它们的信息保存在broker上。kafka-consumer-groups.sh工具可以用于列出上述两种消费者群组。它也可以用于删除消费者群组和偏移量信息,不过这个功能仅限于旧版本的消费者群组(信息保存在Zooke[...]

撰写于    浏览:501 次  分类: kafka研究
可以使用主题工具列出集群里的所有主题。每个主题占用一行输出,主题之间没有特定的顺序。例如:列出集群里的所有主题。kafka-topics .sh --zookeeper z001.example.com:2181/kafka-cluster --listmy-topic - marked for deletionother-topic主题工具还能[...]

撰写于    浏览:487 次  分类: kafka研究
如果一个主题不再被使用,只要它还存在于集群里,就会占用一定数量的磁盘空间和文件句柄。把它删除就可以释放被占用的资源。为了能够删除主题,broker 的delete.topic.enable参数必须被设置为true。如果该参数被设为false,删除主题的请求会被忽略。kafka- topics.sh --zookeeper zoo1.example.[...]

撰写于    浏览:526 次  分类: kafka研究
有时候,我们需要为主题增加分区数量。主题基于分区进行伸缩和复制,增加分区主要是为了扩展主题容量或者降低单个分区的吞吐量。如果要在单个消费者群组内运行更多的消费者,那么主题数量也需要相应增加,因为一个分区只能由群组里的一一个消费者读取。例如:将my-topic主题的分区数量增加到16。kafka-topics.sh --zookeeper z0o1.[...]