"""Run example for aws_msk_lambda_utils.""" from kafka_utils.testing.integration import aws_msk_lambda_utils if __name__ == '__main__': print(aws_msk_lambda_utils.example_usage())