diff --git a/Sources/Kafka/Configuration/KafkaGroupConfiguration.swift b/Sources/Kafka/Configuration/KafkaGroupConfiguration.swift deleted file mode 100644 index ef597fa..0000000 --- a/Sources/Kafka/Configuration/KafkaGroupConfiguration.swift +++ /dev/null @@ -1,37 +0,0 @@ -//===----------------------------------------------------------------------===// -// -// This source file is part of the swift-kafka-client open source project -// -// Copyright (c) 2022 Apple Inc. and the swift-kafka-client project authors -// Licensed under Apache License v2.0 -// -// See LICENSE.txt for license information -// See CONTRIBUTORS.txt for the list of swift-kafka-client project authors -// -// SPDX-License-Identifier: Apache-2.0 -// -//===----------------------------------------------------------------------===// - -public struct KafkaGroupConfiguration { - // MARK: - Common Client Config Properties - - /// Initial list of brokers. - /// Default: `[]` - public var bootstrapBrokerAddresses: [KafkaConfiguration.BrokerAddress] = [] - - public init(bootstrapBrokerAddresses: [KafkaConfiguration.BrokerAddress]) { - self.bootstrapBrokerAddresses = bootstrapBrokerAddresses - } -} - -// MARK: - KafkaGroupConfiguration + Dictionary - -extension KafkaGroupConfiguration { - internal var dictionary: [String: String] { - var resultDict: [String: String] = [:] - resultDict["bootstrap.servers"] = bootstrapBrokerAddresses.map(\.description).joined(separator: ",") - return resultDict - } -} - -extension KafkaGroupConfiguration: Sendable {} diff --git a/Sources/Kafka/KafkaMetadataBroker.swift b/Sources/Kafka/KafkaMetadataBroker.swift deleted file mode 100644 index 6c3ea76..0000000 --- a/Sources/Kafka/KafkaMetadataBroker.swift +++ /dev/null @@ -1,34 +0,0 @@ -//===----------------------------------------------------------------------===// -// -// This source file is part of the swift-kafka-client open source project -// -// Copyright (c) 2023 Apple Inc. and the swift-kafka-client project authors -// Licensed under Apache License v2.0 -// -// See LICENSE.txt for license information -// See CONTRIBUTORS.txt for the list of swift-kafka-client project authors -// -// SPDX-License-Identifier: Apache-2.0 -// -//===----------------------------------------------------------------------===// - -import Crdkafka - -/// A proxy structure for rd_kafka_metadata_broker_t -public struct KafkaMetadataBroker: Sendable, Hashable { - public let id: Int32 - public let host: String - public let port: Int32 - - public init(id: Int32, host: String, port: Int32) { - self.id = id - self.host = host - self.port = port - } - - init(_ rdMetadataBroker: rd_kafka_metadata_broker_t) { - self.id = rdMetadataBroker.id - self.host = String(cString: rdMetadataBroker.host) - self.port = rdMetadataBroker.port - } -}