From c703e83053dc945aa19997dff0c90d02976951e1 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Mon, 20 Apr 2026 09:16:41 -0700 Subject: [PATCH] Admin cli: dont print stacktrace for BrokerResponseError or ValueError --- kafka/cli/admin/__init__.py | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/kafka/cli/admin/__init__.py b/kafka/cli/admin/__init__.py index 7374545cc..024e6c437 100644 --- a/kafka/cli/admin/__init__.py +++ b/kafka/cli/admin/__init__.py @@ -12,6 +12,8 @@ from .topics import TopicsSubCommand from .users import UsersSubCommand from ..common import add_common_cli_args +from kafka.errors import BrokerResponseError + def main_parser(): parser = argparse.ArgumentParser( @@ -91,6 +93,12 @@ def run_cli(args=None): result = result.to_dict() print(json.dumps(result)) return 0 + except BrokerResponseError as exc: + print(exc) + return 1 + except ValueError as exc: + print(exc.args[0]) + return 1 except AttributeError as exc: logger.exception(exc) parser.print_help()