make triggerGracefulShutdown() public (#130)

Author: blindspotbounty

Sources/Kafka/KafkaConsumer.swift

@@ -416,7 +416,7 @@ public final class KafkaConsumer: Sendable, Service {
     ///
     /// - Note: Invoking this function is not always needed as the ``KafkaConsumer``
     /// will already shut down when consumption of the ``KafkaConsumerMessages`` has ended.
-    private func triggerGracefulShutdown() {
+    public func triggerGracefulShutdown() {
         let action = self.stateMachine.withLockedValue { $0.finish() }
         switch action {
         case .triggerGracefulShutdown(let client):

Sources/Kafka/KafkaProducer.swift

@@ -235,7 +235,7 @@ public final class KafkaProducer: Service, Sendable {
     ///
     /// This method flushes any buffered messages and waits until a callback is received for all of them.
     /// Afterwards, it shuts down the connection to Kafka and cleans any remaining state up.
-    private func triggerGracefulShutdown() {
+    public func triggerGracefulShutdown() {
         self.stateMachine.withLockedValue { $0.finish() }
     }