部署在Kubernetes Pod中的Kafka Topic是否仍保持不可变性？

Kubernetes中Kafka Topic的不可变性说明 #

• Kafka Topic的核心配置（比如cleanup.policy、分区数、副本数）本身就是不可变的，和部署环境无关——不管是跑在Kubernetes还是物理机上，已创建的Topic属性不会因为重启Pod或修改部署清单就自动更新。
• 你修改清单后重启Pod，只会影响新创建的Topic，对已经存在的_schemas这类Topic完全无效。

Schema Registry CrashLoopBackOff 修复步骤 #

日志里的错误很明确：Schema Registry依赖的_schemas Topic清理策略错误，cleanup.policy被设成了delete，但它要求必须是compact。

按以下步骤修复：

1. 进入Kafka Broker的Pod：

   kubectl exec -it <kafka-broker-pod-name> -- /bin/bash
   

2. 执行Kafka配置修改命令，把_schemas的清理策略改成compact：

   kafka-configs.sh --bootstrap-server <kafka-bootstrap-service>:9092 --alter --entity-type topics --entity-name _schemas --add-config cleanup.policy=compact
   

   注：<kafka-broker-pod-name>换成实际的Broker Pod名称，<kafka-bootstrap-service>换成K8s里Kafka的服务名（比如kafka-cluster-kafka-bootstrap）。
3. 退出Broker Pod，重启Schema Registry的Pod：

   kubectl delete pod <schema-registry-pod-name>
   

   K8s会自动重新创建一个正常的Pod。

后续注意事项 #

• 以后修改Kafka Topic配置，别只改部署清单——清单里的配置仅在首次创建Topic时生效，已存在的Topic必须用Kafka的命令行工具或者API去修改。
• _schemas Topic是Schema Registry的核心依赖，一定要保证它的cleanup.policy是compact，不然Schema Registry没法保留历史Schema版本，必然启动失败。

内容的提问来源于stack exchange，提问作者生きがい