如何阻止Kafka主题接收新消息？需保留读取权限且不影响其他主题

当然可以，有几种可靠的方法可以实现这个需求，同时不影响其他主题的正常运行：

方法1：通过ACL拒绝写入权限 #

这是最精准且安全的方式，直接针对目标主题限制写入操作，完全不影响读取和其他主题。

• 操作命令（使用Kafka自带的脚本）：

  kafka-acls.sh --bootstrap-server <你的Kafka broker地址>:9092 --command-config <客户端配置文件>.properties --add --deny-principal User:* --operation Write --topic <目标主题名称>
  

• 细节说明：
  • 这条命令会拒绝所有用户对目标主题的写入权限，读取权限不受任何影响。
  • 如果需要给特定生产者保留写入权限，只需调整--deny-principal的范围（比如只拒绝某个特定用户User:bad-producer）。
  • 恢复写入时，执行相同命令把--add换成--remove即可。

方法2：修改主题的min.insync.replicas配置 #

通过调整同步副本要求，让生产者无法完成消息确认，从而阻止写入。

• 操作命令：
  首先确认目标主题的副本数（假设当前副本数为3），然后将min.insync.replicas设为大于当前可用的同步副本数：

  kafka-configs.sh --bootstrap-server <你的Kafka broker地址>:9092 --alter --entity-type topics --entity-name <目标主题名称> --add-config min.insync.replicas=4
  

• 细节说明：
  • 仅当生产者使用默认的acks=all时生效，如果生产者设置了acks=1或acks=0，这个方法会失效（因为不需要等待所有同步副本确认）。
  • 执行后，生产者发送消息会抛出NotEnoughReplicasException，无法写入，但读取操作完全正常。
  • 恢复时，将配置改回原来的值即可，比如min.insync.replicas=2。

注意事项 #

• 所有操作前请先在测试环境验证，避免影响生产集群。
• 确保你拥有足够的权限执行配置修改或ACL操作（通常需要集群管理员权限）。
• 如果使用ACL方案，记得检查是否有其他依赖该主题写入的服务，避免误影响。

内容的提问来源于stack exchange，提问作者Iwan Satria