Skip to content

Commit 63019e2

Browse files
authored
removing kafka statefulset before upgrade (#1432)
1 parent 495ffd4 commit 63019e2

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

platform/services/installer/app/platform_stages/steps/apply_minor_version_changes/remove_previous_k8s_objects.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -87,6 +87,8 @@ def _remove_stateful_set():
8787
try:
8888
logger.debug("Deleting etcd stateful set.")
8989
core_api.delete_namespaced_stateful_set(name="impt-etcd", namespace="impt")
90+
logger.debug("Deleting kafka stateful set.")
91+
core_api.delete_namespaced_stateful_set(name="impt-kafka", namespace="impt")
9092
except kubernetes.client.exceptions.ApiException as ex:
9193
if ex.status != 404:
9294
logger.error("Error when accessing the Kubernetes API.", exc_info=True)

0 commit comments

Comments
 (0)