赞
踩
参考:【Kafka】Kafka集群扩展以及重新分布分区
假如初始时chatmessage为一个副本,为了提高可用性,需要改为2副本模式。脚本replicas-chatmessage-topic.json文件内容如下:
{ "partitions": [ { "topic":