apache-kafka - 如何减少Kafka主题的分区数量?

标签 apache-kafka

我在 Kafka 上创建了一个有 4 个分区的主题。 (设置默认值 number.partition=4 )。现在我想将此主题的编号分区更改为 3。
我试过运行

./bin/kafka-topics.sh --alter --zookeeper localhost:2181 --topic my-topic --partitions 3

但没有变化。它仍然有4个分区。
有人知道这件事吗?

最佳答案

Apache Kafka 不支持减少分区数。您应该将整个主题视为一个整体,分区是一种扩展以提高性能的方式。因此,发送到主题的所有数据都会流向所有分区,删除其中一个分区意味着数据丢失。

关于apache-kafka - 如何减少Kafka主题的分区数量?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/45497878/

相关文章:

java - 如何实现 FlinkKafkaPartitioner?

java - Spring Cloud Contracts - 没有为主题设置消费者[...]

apache-kafka - 在没有 Confluent Schema Registry 的情况下在 KafkaConnect 中使用 Avro

apache-kafka - 增加一次Kafka用户在一次民意调查中阅读的邮件数量

ssl - kafka : Inbound closed before receiving peer's close_notify 中的 SSL 错误

apache-kafka - 变更日志/重新分区主题的复制因子应该是多少

apache-kafka - Kafka 转储日志消息不显示负载

kotlin - 当我使用多个流时,Kafka Streams StreamsException

apache-kafka - 当 Kafka Broker 关闭并恢复时,kafka 生产者中的数据丢失

apache-kafka - 多代理,多服务器群集中的Kafka生产者无法写入新创建的主题