bmingithub 你这个场景的应用算是有状态的了,因为每个pod的kafka topic是不一样的。 可以试下使用statefulset, 那样pod的名字是“mqtt-0” "mqtt-1″这样。