diff --git a/utils/kafka/status.py b/utils/kafka/status.py index 8331a056dff..ff2db1b1265 100755 --- a/utils/kafka/status.py +++ b/utils/kafka/status.py @@ -46,6 +46,7 @@ def main(): consumer.close() client.close() + return 0 if __name__ == "__main__":