public struct KafkaProducerConfig: Hashable, Equatable {         set { self.dictionary["message.send.max.retries"] = String(newValue) }     } +    /// Allow automatic topic creation on the broker when subscribing to or assigning non-existent topics. The broker must also be configured with auto.create.topics.enable=true for this configuration to take effect. Note: the default value (true) for the producer is different from the default value (false) for the consumer. Further, the consumer default value is different from the Java consumer (true), and this property is not supported by the Java producer. Requires broker version >= 0.11.0.0, for older broker versions only the broker configuration applies.

 public struct KafkaProducerConfig: Hashable, Equatable {         set { self.dictionary["message.send.max.retries"] = String(newValue) }     } +    /// Allow automatic topic creation on the broker when subscribing to or assigning non-existent topics. The broker must also be configured with auto.create.topics.enable=true for this configuration to take effect. Note: the default value (true) for the producer is different from the default value (false) for the consumer. Further, the consumer default value is different from the Java consumer (true), and this property is not supported by the Java producer. Requires broker version >= 0.11.0.0, for older broker versions only the broker configuration applies.

 public struct KafkaProducerConfig: Hashable, Equatable {         set { self.dictionary["message.send.max.retries"] = String(newValue) }     } +    /// Allow automatic topic creation on the broker when subscribing to or assigning non-existent topics. The broker must also be configured with auto.create.topics.enable=true for this configuration to take effect. Note: the default value (true) for the producer is different from the default value (false) for the consumer. Further, the consumer default value is different from the Java consumer (true), and this property is not supported by the Java producer. Requires broker version >= 0.11.0.0, for older broker versions only the broker configuration applies.

 public struct KafkaProducerConfig: Hashable, Equatable {         set { self.dictionary["message.send.max.retries"] = String(newValue) }     } +    /// Allow automatic topic creation on the broker when subscribing to or assigning non-existent topics. The broker must also be configured with auto.create.topics.enable=true for this configuration to take effect. Note: the default value (true) for the producer is different from the default value (false) for the consumer. Further, the consumer default value is different from the Java consumer (true), and this property is not supported by the Java producer. Requires broker version >= 0.11.0.0, for older broker versions only the broker configuration applies.

 public struct KafkaConsumerConfig: Hashable, Equatable {      // MARK: - Helpers -    func getDebugOptions() -> [KafkaSharedConfiguration.DebugOption] {+    func getDebugOptions() -> [ConfigEnums.DebugOption] {         guard let options = dictionary["debug"] else {             return []         }         return options.components(separatedBy: ",")-            .map { KafkaSharedConfiguration.DebugOption(description: $0) }+            .map { ConfigEnums.DebugOption(description: $0) }     } -    func getIPAddressFamily() -> KafkaSharedConfiguration.IPAddressFamily? {+    func getIPAddressFamily() -> ConfigEnums.IPAddressFamily? {         guard let value = dictionary["broker.address.family"] else {             return nil         }-        return KafkaSharedConfiguration.IPAddressFamily(description: value)+        return ConfigEnums.IPAddressFamily(description: value)     } -    func getSecurityProtocol() -> KafkaSharedConfiguration.SecurityProtocol? {+    func getSecurityProtocol() -> ConfigEnums.SecurityProtocol? {         guard let value = dictionary["security.protocol"] else {             return nil         }-        return KafkaSharedConfiguration.SecurityProtocol(description: value)+        return ConfigEnums.SecurityProtocol(description: value)     } -    func getSASLMechanism() -> KafkaSharedConfiguration.SASLMechanism? {+    func getSASLMechanism() -> ConfigEnums.SASLMechanism? {         guard let value = dictionary["sasl.mechanism"] else {             return nil         }-        return KafkaSharedConfiguration.SASLMechanism(description: value)+        return ConfigEnums.SASLMechanism(description: value)     } -    func getAutoOffsetReset() -> KafkaSharedConfiguration.AutoOffsetReset? {+    func getAutoOffsetReset() -> ConfigEnums.AutoOffsetReset? {         guard let value = dictionary["auto.offset.reset"] else {             return nil         }-        return KafkaSharedConfiguration.AutoOffsetReset(description: value)+        return ConfigEnums.AutoOffsetReset(description: value)     } }  // MARK: - ConfigEnums + AutoOffsetReset -extension KafkaSharedConfiguration {+extension ConfigEnums {+    /// A struct representing different back pressure strategies for receiving message acknowledgements in ``KafkaConsumer``.

 // //===----------------------------------------------------------------------===// +import Crdkafka+import struct Foundation.UUID+ public struct KafkaConsumerConfig: Hashable, Equatable {+    // MARK: - SwiftKafka-specific Config properties++    /// The backpressure strategy to be used for receiveing message acknowledgements.+    public var backPressureStrategy: ConfigEnums.BackPressureStrategy = .highLowWatermark(+        lowWatermark: 10,+        highWatermark: 50+    )++    // Implicitly unwrapped, because this just backs+    // the non-optional consumptionStrategy variable+    private var _consumptionStrategy: ConfigEnums.ConsumptionStrategy!