diff --git a/kafka/cli/admin/__init__.py b/kafka/cli/admin/__init__.py index eff561a6c..d7e4e45c0 100644 --- a/kafka/cli/admin/__init__.py +++ b/kafka/cli/admin/__init__.py @@ -95,6 +95,10 @@ def run_cli(args=None): result = result.to_dict() print(json.dumps(result)) return 0 + except AttributeError as exc: + logger.exception(exc) + parser.print_help() + return 1 except Exception: logger.critical('Error!', exc_info=True) return 1