Skip to content

Commit e13b447

Browse files
authored
Adding logging for errors on setting client side properties (#20)
1 parent efbdad5 commit e13b447

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

cfn_kafka_admin/lambda_functions/topics.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@
2020
from cfn_kafka_admin.kafka_resources.topics.update import update_kafka_topic
2121
from cfn_kafka_admin.models.admin import EwsKafkaTopic
2222

23-
from .utils import cfn_resolve_string, define_cluster_info, set_client_info
23+
from .utils import set_client_info
2424

2525
LOG = setup_logging(__name__)
2626

cfn_kafka_admin/lambda_functions/utils.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -51,10 +51,14 @@ def set_client_info(cfn_resource: ResourceProvider):
5151
try:
5252
define_cluster_info(cfn_resource)
5353
except Exception as error:
54+
LOG.error("Failed to set properties for Kafka Cluster")
55+
LOG.exception(error)
5456
cfn_resource.fail(str(error))
5557
else:
5658
cfn_resource.cluster_info = client_config
5759
try:
5860
cfn_resolve_string(cfn_resource)
5961
except Exception as error:
60-
cfn_resource.fail(str(error))
62+
LOG.error("Failed to retrieve Secret resolve string value.")
63+
LOG.exception(error)
64+
cfn_resource.fail("SecretsResolve failed " + str(error))

0 commit comments

Comments
 (0)