diff --git a/src/ConfluentKafkaLibrary/admin_client.py b/src/ConfluentKafkaLibrary/admin_client.py index dc5a5dd..5813531 100644 --- a/src/ConfluentKafkaLibrary/admin_client.py +++ b/src/ConfluentKafkaLibrary/admin_client.py @@ -230,4 +230,10 @@ def alter_configs(self, group_id, resources, **kwargs): return f"Failed to alter config {config.name}: {e}" except (TypeError, ValueError ) as e: return f"Invalid input: {e}" - return config_results \ No newline at end of file + return config_results + + def close_admin(self, group_id): + """Close down and terminate the Kafka Admin. + """ + # simply deleting client will close connection + del self.admin_clients[group_id] \ No newline at end of file