Swift Package IndexBuild Information
Failed to build Franz, reference master (c39cd2), with Swift 6.3 for Wasm on 10 Apr 2026 10:00:55 UTC.
Build Command
bash -c docker run --pull=always --rm -v "checkouts-4609320-2":/host -w "$PWD" -e JAVA_HOME="/root/.sdkman/candidates/java/current" -e SPI_BUILD="1" -e SPI_PROCESSING="1" registry.gitlab.com/swiftpackageindex/spi-images:wasm-6.3-latest swift build --swift-sdk swift-6.3-RELEASE_wasm 2>&1Build Log
========================================
RunAll
========================================
Builder version: 4.70.0
Interrupt handler set up.
========================================
Checkout
========================================
Clone URL: https://github.com/kellanburket/franz.git
Reference: master
Initialized empty Git repository in /host/spi-builder-workspace/.git/
hint: Using 'master' as the name for the initial branch. This default branch name
hint: is subject to change. To configure the initial branch name to use in all
hint: of your new repositories, which will suppress this warning, call:
hint:
hint: git config --global init.defaultBranch <name>
hint:
hint: Names commonly chosen instead of 'master' are 'main', 'trunk' and
hint: 'development'. The just-created branch can be renamed via this command:
hint:
hint: git branch -m <name>
From https://github.com/kellanburket/franz
* branch master -> FETCH_HEAD
* [new branch] master -> origin/master
HEAD is now at c39cd28 Merge pull request #14 from lewissk/master
Cloned https://github.com/kellanburket/franz.git
Revision (git rev-parse @):
c39cd28aa8d78ab8446a50eb328993df99374a30
SUCCESS checkout https://github.com/kellanburket/franz.git at master
========================================
Build
========================================
Selected platform: wasm
Swift version: 6.3
Building package at path: $PWD
https://github.com/kellanburket/franz.git
Running build ...
bash -c docker run --pull=always --rm -v "checkouts-4609320-2":/host -w "$PWD" -e JAVA_HOME="/root/.sdkman/candidates/java/current" -e SPI_BUILD="1" -e SPI_PROCESSING="1" registry.gitlab.com/swiftpackageindex/spi-images:wasm-6.3-latest swift build --swift-sdk swift-6.3-RELEASE_wasm 2>&1
wasm-6.3-latest: Pulling from swiftpackageindex/spi-images
Digest: sha256:d69f4e7582c319245442d62a08b2d7c7fd5a0c0c69f5d2ef11d1530cd8d3329b
Status: Image is up to date for registry.gitlab.com/swiftpackageindex/spi-images:wasm-6.3-latest
Building for debugging...
[0/2] Write sources
[1/2] Write swift-version-24593BA9C3E375BF.txt
error: emit-module command failed with exit code 1 (use -v to see invocation)
[3/29] Emitting module Franz
/host/spi-builder-workspace/Sources/Franz/API/GroupMembershipAPI.swift:419:25: warning: generic parameter 'T' shadows generic parameter from outer scope with the same name; this is an error in the Swift 6 language mode
371 | typealias MemberId = String
372 |
373 | struct SyncGroupRequestMessage<T: KafkaMetadata>: KafkaType {
| `- note: 'T' previously declared here
374 |
375 | private var _groupId: String
:
417 | }
418 |
419 | struct GroupAssignment<T: KafkaMetadata>: KafkaType {
| `- warning: generic parameter 'T' shadows generic parameter from outer scope with the same name; this is an error in the Swift 6 language mode
420 |
421 | let memberId: String
/host/spi-builder-workspace/Sources/Franz/Broker.swift:491:39: error: cannot find type 'DispatchQueue' in scope
489 | private var _readQueues = [Int32: DispatchQueue]()
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
492 | return DispatchQueue(
493 | label: "metadata.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:498:40: error: cannot find type 'DispatchQueue' in scope
496 | }()
497 |
498 | private lazy var _metadataWriteQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
499 | return DispatchQueue(
500 | label: "metadata.write.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:505:36: error: cannot find type 'DispatchQueue' in scope
503 | }()
504 |
505 | private lazy var _adminReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
506 | return DispatchQueue(
507 | label: "admin.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:512:44: error: cannot find type 'DispatchQueue' in scope
510 | }()
511 |
512 | private lazy var _groupCoordinationQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
513 | return DispatchQueue(
514 | label: "group.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:472:69: error: cannot find type 'DispatchQueue' in scope
470 | }
471 |
472 | private func getReadQueue(_ topic: String, partition: Int32) -> DispatchQueue {
| `- error: cannot find type 'DispatchQueue' in scope
473 | var readQueue: DispatchQueue
474 | if let pq = _readQueues[partition] {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:489:36: error: cannot find 'DispatchQueue' in scope
487 | //MARK: Queues
488 |
489 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot find 'DispatchQueue' in scope
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:489:29: error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
487 | //MARK: Queues
488 |
489 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:489:28: error: cannot call value of non-function type '[AnyHashable : Any]'
487 | //MARK: Queues
488 |
489 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot call value of non-function type '[AnyHashable : Any]'
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:492:10: error: cannot find 'DispatchQueue' in scope
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
492 | return DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
493 | label: "metadata.read.stream.franz",
494 | attributes: []
/host/spi-builder-workspace/Sources/Franz/Broker.swift:499:10: error: cannot find 'DispatchQueue' in scope
497 |
498 | private lazy var _metadataWriteQueue: DispatchQueue = {
499 | return DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
500 | label: "metadata.write.stream.franz",
501 | attributes: []
/host/spi-builder-workspace/Sources/Franz/Broker.swift:506:10: error: cannot find 'DispatchQueue' in scope
504 |
505 | private lazy var _adminReadQueue: DispatchQueue = {
506 | return DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
507 | label: "admin.read.stream.franz",
508 | attributes: []
/host/spi-builder-workspace/Sources/Franz/Broker.swift:513:10: error: cannot find 'DispatchQueue' in scope
511 |
512 | private lazy var _groupCoordinationQueue: DispatchQueue = {
513 | return DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
514 | label: "group.read.stream.franz",
515 | attributes: []
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:35:29: error: cannot find type 'DispatchQueue' in scope
33 | let nodeId: ReplicaId
34 |
35 | lazy var dispatchQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
36 | return DispatchQueue(label: "metadata.cluster.read.stream.franz")
37 | }()
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:36:16: error: cannot find 'DispatchQueue' in scope
34 |
35 | lazy var dispatchQueue: DispatchQueue = {
36 | return DispatchQueue(label: "metadata.cluster.read.stream.franz")
| `- error: cannot find 'DispatchQueue' in scope
37 | }()
38 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:89:39: error: cannot find type 'CFReadStream' in scope
87 | private var clientId: String
88 |
89 | private var readStream: Unmanaged<CFReadStream>?
| `- error: cannot find type 'CFReadStream' in scope
90 | private var writeStream: Unmanaged<CFWriteStream>?
91 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:90:40: error: cannot find type 'CFWriteStream' in scope
88 |
89 | private var readStream: Unmanaged<CFReadStream>?
90 | private var writeStream: Unmanaged<CFWriteStream>?
| `- error: cannot find type 'CFWriteStream' in scope
91 |
92 | private var inputStream: InputStream?
/host/spi-builder-workspace/Sources/Franz/Connection.swift:98:35: error: cannot find type 'DispatchQueue' in scope
96 | private let responseCorrelationIdSize: Int32 = 4
97 |
98 | private var inputStreamQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
99 | private var outputStreamQueue: DispatchQueue
100 | private var writeRequestBlocks = [()->()]()
/host/spi-builder-workspace/Sources/Franz/Connection.swift:99:36: error: cannot find type 'DispatchQueue' in scope
97 |
98 | private var inputStreamQueue: DispatchQueue
99 | private var outputStreamQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
100 | private var writeRequestBlocks = [()->()]()
101 |
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:22:38: error: cannot find 'DispatchSemaphore' in scope
20 | internal var broker: Broker?
21 | internal var membership: GroupMembership?
22 | internal let joinedGroupSemaphore = DispatchSemaphore(value: 0)
| `- error: cannot find 'DispatchSemaphore' in scope
23 |
24 | var groupOffsetsTimer: Timer!
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:40:28: error: cannot find 'DispatchQueue' in scope
38 | }
39 |
40 | private let listenQueue = DispatchQueue(label: "FranzConsumerListenQueue")
| `- error: cannot find 'DispatchQueue' in scope
41 |
42 | var offsetsToCommit = [TopicName: [PartitionId: (Offset, OffsetMetadata?)]]()
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:43:3: error: Objective-C interoperability is disabled
41 |
42 | var offsetsToCommit = [TopicName: [PartitionId: (Offset, OffsetMetadata?)]]()
43 | @objc private func commitGroupoffsets() {
| `- error: Objective-C interoperability is disabled
44 | guard let groupId = self.membership?.group.id, let broker = self.broker else { return }
45 | broker.commitGroupOffset(groupId: groupId, topics: offsetsToCommit)
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:48:3: error: Objective-C interoperability is disabled
46 | }
47 |
48 | @objc private func sendHeartbeat() {
| `- error: Objective-C interoperability is disabled
49 | guard let groupId = self.membership?.group.id,
50 | let generationId = self.membership?.group.generationId,
/host/spi-builder-workspace/Sources/Franz/Crypt/CRC32.swift:145:9: warning: 'Hashable.hashValue' is deprecated as a protocol requirement; conform type 'CRC32' to 'Hashable' by implementing 'hash(into:)' instead [#DeprecatedDeclaration]
143 | private(set) var crc: UInt32 = 0
144 |
145 | var hashValue: Int {
| `- warning: 'Hashable.hashValue' is deprecated as a protocol requirement; conform type 'CRC32' to 'Hashable' by implementing 'hash(into:)' instead [#DeprecatedDeclaration]
146 | return Int(crc)
147 | }
/host/spi-builder-workspace/Sources/Franz/Group.swift:72:2: warning: 'internal(set)' modifier is redundant for an internal property
70 |
71 | var topics = Set<TopicName>()
72 | internal(set) var assignedPartitions = [TopicName: [PartitionId]]()
| `- warning: 'internal(set)' modifier is redundant for an internal property
73 | }
74 |
/host/spi-builder-workspace/Sources/Franz/MessageSet.swift:12:2: error: Objective-C interoperability is disabled
10 |
11 |
12 | @objc public class MessageSet: NSObject, KafkaType {
| `- error: Objective-C interoperability is disabled
13 | let values: [MessageSetItem]
14 |
/host/spi-builder-workspace/Sources/Franz/MessageSet.swift:168:2: error: Objective-C interoperability is disabled
166 | */
167 | //TODO: Convert to struct
168 | @objc public class Message: NSObject {
| `- error: Objective-C interoperability is disabled
169 |
170 | /**
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:13:2: error: Objective-C interoperability is disabled
11 | Base consumer delegate. Used by SimpleConsumer.
12 | */
13 | @objc public protocol ConsumerDelegate {
| `- error: Objective-C interoperability is disabled
14 | /**
15 | Called when the consumer has consumed a new Message
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:31:3: error: Objective-C interoperability is disabled
29 | - Parameter errorDescription: a description of the error returned from the server
30 | */
31 | @objc optional func fetchDidFail(
| `- error: Objective-C interoperability is disabled
32 | _ topic: String,
33 | partition: Int32,
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:49:3: error: Objective-C interoperability is disabled
47 | - Returns: true if broker should attempt to retry request, false if not
48 | */
49 | @objc optional func shouldRetryFailedFetch(
| `- error: Objective-C interoperability is disabled
50 | _ topic: String,
51 | partition: Int32,
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:69:3: error: Objective-C interoperability is disabled
67 | - Parameter partition: the partition
68 | */
69 | @objc optional func topicPartitionLeaderNotFound(_ topic: String, partition: Int32)
| `- error: Objective-C interoperability is disabled
70 | }
71 |
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:76:2: error: Objective-C interoperability is disabled
74 | High-level consumer delegate. Used by HighLevelConsumer.
75 | */
76 | @objc public protocol HighLevelConsumerDelegate: ConsumerDelegate {
| `- error: Objective-C interoperability is disabled
77 | /**
78 | Called after messages have been pulled for server.
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:86:3: error: Objective-C interoperability is disabled
84 | - Returns: true if offset should be committed, false if otherwise
85 | */
86 | @objc optional func shouldCommitOffset(_ topic: String, partition: Int32, offset: Int64) -> Bool
| `- error: Objective-C interoperability is disabled
87 |
88 | /**
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:97:3: error: Objective-C interoperability is disabled
95 | - Returns: additional metadata to send with offset commit to server
96 | */
97 | @objc optional func shouldAttachOffsetMetadata(_ topic: String, partition: Int32, offset: Int64) -> String?
| `- error: Objective-C interoperability is disabled
98 |
99 | /**
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:106:3: error: Objective-C interoperability is disabled
104 | - Parameter offset: the offset
105 | */
106 | @objc optional func offsetDidCommit(_ topic: String, partition: Int32, offset: Int64)
| `- error: Objective-C interoperability is disabled
107 |
108 | /**
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:117:3: error: Objective-C interoperability is disabled
115 | - Parameter errorDescription: description of the error
116 | */
117 | @objc optional func offsetCommitDidFail(_ topic: String, partition: Int32, offset: Int64, errorId: Int16, errorDescription: String)
| `- error: Objective-C interoperability is disabled
118 |
119 | /**
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:130:3: error: Objective-C interoperability is disabled
128 | - Returns: true if offset commit should be retried, false if otherwise
129 | */
130 | @objc optional func shouldRetryFailedOffsetCommit(_ topic: String, partition: Int32, offset: Int64, errorId: Int16, errorDescription: String) -> Bool
| `- error: Objective-C interoperability is disabled
131 | }
132 |
[#DeprecatedDeclaration]: <https://docs.swift.org/compiler/documentation/diagnostics/deprecated-declaration>
[4/32] Compiling Franz PlainMechanism.swift
/host/spi-builder-workspace/Sources/Franz/Connection.swift:89:39: error: cannot find type 'CFReadStream' in scope
87 | private var clientId: String
88 |
89 | private var readStream: Unmanaged<CFReadStream>?
| `- error: cannot find type 'CFReadStream' in scope
90 | private var writeStream: Unmanaged<CFWriteStream>?
91 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:90:40: error: cannot find type 'CFWriteStream' in scope
88 |
89 | private var readStream: Unmanaged<CFReadStream>?
90 | private var writeStream: Unmanaged<CFWriteStream>?
| `- error: cannot find type 'CFWriteStream' in scope
91 |
92 | private var inputStream: InputStream?
/host/spi-builder-workspace/Sources/Franz/Connection.swift:98:35: error: cannot find type 'DispatchQueue' in scope
96 | private let responseCorrelationIdSize: Int32 = 4
97 |
98 | private var inputStreamQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
99 | private var outputStreamQueue: DispatchQueue
100 | private var writeRequestBlocks = [()->()]()
/host/spi-builder-workspace/Sources/Franz/Connection.swift:99:36: error: cannot find type 'DispatchQueue' in scope
97 |
98 | private var inputStreamQueue: DispatchQueue
99 | private var outputStreamQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
100 | private var writeRequestBlocks = [()->()]()
101 |
[5/32] Compiling Franz SaslMechanism.swift
/host/spi-builder-workspace/Sources/Franz/Connection.swift:89:39: error: cannot find type 'CFReadStream' in scope
87 | private var clientId: String
88 |
89 | private var readStream: Unmanaged<CFReadStream>?
| `- error: cannot find type 'CFReadStream' in scope
90 | private var writeStream: Unmanaged<CFWriteStream>?
91 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:90:40: error: cannot find type 'CFWriteStream' in scope
88 |
89 | private var readStream: Unmanaged<CFReadStream>?
90 | private var writeStream: Unmanaged<CFWriteStream>?
| `- error: cannot find type 'CFWriteStream' in scope
91 |
92 | private var inputStream: InputStream?
/host/spi-builder-workspace/Sources/Franz/Connection.swift:98:35: error: cannot find type 'DispatchQueue' in scope
96 | private let responseCorrelationIdSize: Int32 = 4
97 |
98 | private var inputStreamQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
99 | private var outputStreamQueue: DispatchQueue
100 | private var writeRequestBlocks = [()->()]()
/host/spi-builder-workspace/Sources/Franz/Connection.swift:99:36: error: cannot find type 'DispatchQueue' in scope
97 |
98 | private var inputStreamQueue: DispatchQueue
99 | private var outputStreamQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
100 | private var writeRequestBlocks = [()->()]()
101 |
[6/32] Compiling Franz Topic.swift
/host/spi-builder-workspace/Sources/Franz/Connection.swift:89:39: error: cannot find type 'CFReadStream' in scope
87 | private var clientId: String
88 |
89 | private var readStream: Unmanaged<CFReadStream>?
| `- error: cannot find type 'CFReadStream' in scope
90 | private var writeStream: Unmanaged<CFWriteStream>?
91 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:90:40: error: cannot find type 'CFWriteStream' in scope
88 |
89 | private var readStream: Unmanaged<CFReadStream>?
90 | private var writeStream: Unmanaged<CFWriteStream>?
| `- error: cannot find type 'CFWriteStream' in scope
91 |
92 | private var inputStream: InputStream?
/host/spi-builder-workspace/Sources/Franz/Connection.swift:98:35: error: cannot find type 'DispatchQueue' in scope
96 | private let responseCorrelationIdSize: Int32 = 4
97 |
98 | private var inputStreamQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
99 | private var outputStreamQueue: DispatchQueue
100 | private var writeRequestBlocks = [()->()]()
/host/spi-builder-workspace/Sources/Franz/Connection.swift:99:36: error: cannot find type 'DispatchQueue' in scope
97 |
98 | private var inputStreamQueue: DispatchQueue
99 | private var outputStreamQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
100 | private var writeRequestBlocks = [()->()]()
101 |
[7/32] Compiling Franz GroupCoordinatorAPI.swift
/host/spi-builder-workspace/Sources/Franz/API/GroupMembershipAPI.swift:419:25: warning: generic parameter 'T' shadows generic parameter from outer scope with the same name; this is an error in the Swift 6 language mode
371 | typealias MemberId = String
372 |
373 | struct SyncGroupRequestMessage<T: KafkaMetadata>: KafkaType {
| `- note: 'T' previously declared here
374 |
375 | private var _groupId: String
:
417 | }
418 |
419 | struct GroupAssignment<T: KafkaMetadata>: KafkaType {
| `- warning: generic parameter 'T' shadows generic parameter from outer scope with the same name; this is an error in the Swift 6 language mode
420 |
421 | let memberId: String
/host/spi-builder-workspace/Sources/Franz/Broker.swift:491:39: error: cannot find type 'DispatchQueue' in scope
489 | private var _readQueues = [Int32: DispatchQueue]()
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
492 | return DispatchQueue(
493 | label: "metadata.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:498:40: error: cannot find type 'DispatchQueue' in scope
496 | }()
497 |
498 | private lazy var _metadataWriteQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
499 | return DispatchQueue(
500 | label: "metadata.write.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:505:36: error: cannot find type 'DispatchQueue' in scope
503 | }()
504 |
505 | private lazy var _adminReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
506 | return DispatchQueue(
507 | label: "admin.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:512:44: error: cannot find type 'DispatchQueue' in scope
510 | }()
511 |
512 | private lazy var _groupCoordinationQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
513 | return DispatchQueue(
514 | label: "group.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:489:36: error: cannot find 'DispatchQueue' in scope
487 | //MARK: Queues
488 |
489 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot find 'DispatchQueue' in scope
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:489:29: error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
487 | //MARK: Queues
488 |
489 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:489:28: error: cannot call value of non-function type '[AnyHashable : Any]'
487 | //MARK: Queues
488 |
489 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot call value of non-function type '[AnyHashable : Any]'
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
[8/32] Compiling Franz GroupMembershipAPI.swift
/host/spi-builder-workspace/Sources/Franz/API/GroupMembershipAPI.swift:419:25: warning: generic parameter 'T' shadows generic parameter from outer scope with the same name; this is an error in the Swift 6 language mode
371 | typealias MemberId = String
372 |
373 | struct SyncGroupRequestMessage<T: KafkaMetadata>: KafkaType {
| `- note: 'T' previously declared here
374 |
375 | private var _groupId: String
:
417 | }
418 |
419 | struct GroupAssignment<T: KafkaMetadata>: KafkaType {
| `- warning: generic parameter 'T' shadows generic parameter from outer scope with the same name; this is an error in the Swift 6 language mode
420 |
421 | let memberId: String
/host/spi-builder-workspace/Sources/Franz/Broker.swift:491:39: error: cannot find type 'DispatchQueue' in scope
489 | private var _readQueues = [Int32: DispatchQueue]()
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
492 | return DispatchQueue(
493 | label: "metadata.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:498:40: error: cannot find type 'DispatchQueue' in scope
496 | }()
497 |
498 | private lazy var _metadataWriteQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
499 | return DispatchQueue(
500 | label: "metadata.write.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:505:36: error: cannot find type 'DispatchQueue' in scope
503 | }()
504 |
505 | private lazy var _adminReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
506 | return DispatchQueue(
507 | label: "admin.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:512:44: error: cannot find type 'DispatchQueue' in scope
510 | }()
511 |
512 | private lazy var _groupCoordinationQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
513 | return DispatchQueue(
514 | label: "group.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:489:36: error: cannot find 'DispatchQueue' in scope
487 | //MARK: Queues
488 |
489 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot find 'DispatchQueue' in scope
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:489:29: error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
487 | //MARK: Queues
488 |
489 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:489:28: error: cannot call value of non-function type '[AnyHashable : Any]'
487 | //MARK: Queues
488 |
489 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot call value of non-function type '[AnyHashable : Any]'
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
[9/32] Compiling Franz MetadataAPI.swift
/host/spi-builder-workspace/Sources/Franz/API/GroupMembershipAPI.swift:419:25: warning: generic parameter 'T' shadows generic parameter from outer scope with the same name; this is an error in the Swift 6 language mode
371 | typealias MemberId = String
372 |
373 | struct SyncGroupRequestMessage<T: KafkaMetadata>: KafkaType {
| `- note: 'T' previously declared here
374 |
375 | private var _groupId: String
:
417 | }
418 |
419 | struct GroupAssignment<T: KafkaMetadata>: KafkaType {
| `- warning: generic parameter 'T' shadows generic parameter from outer scope with the same name; this is an error in the Swift 6 language mode
420 |
421 | let memberId: String
/host/spi-builder-workspace/Sources/Franz/Broker.swift:491:39: error: cannot find type 'DispatchQueue' in scope
489 | private var _readQueues = [Int32: DispatchQueue]()
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
492 | return DispatchQueue(
493 | label: "metadata.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:498:40: error: cannot find type 'DispatchQueue' in scope
496 | }()
497 |
498 | private lazy var _metadataWriteQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
499 | return DispatchQueue(
500 | label: "metadata.write.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:505:36: error: cannot find type 'DispatchQueue' in scope
503 | }()
504 |
505 | private lazy var _adminReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
506 | return DispatchQueue(
507 | label: "admin.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:512:44: error: cannot find type 'DispatchQueue' in scope
510 | }()
511 |
512 | private lazy var _groupCoordinationQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
513 | return DispatchQueue(
514 | label: "group.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:489:36: error: cannot find 'DispatchQueue' in scope
487 | //MARK: Queues
488 |
489 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot find 'DispatchQueue' in scope
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:489:29: error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
487 | //MARK: Queues
488 |
489 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:489:28: error: cannot call value of non-function type '[AnyHashable : Any]'
487 | //MARK: Queues
488 |
489 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot call value of non-function type '[AnyHashable : Any]'
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
[10/32] Compiling Franz OffsetAPI.swift
/host/spi-builder-workspace/Sources/Franz/API/GroupMembershipAPI.swift:419:25: warning: generic parameter 'T' shadows generic parameter from outer scope with the same name; this is an error in the Swift 6 language mode
371 | typealias MemberId = String
372 |
373 | struct SyncGroupRequestMessage<T: KafkaMetadata>: KafkaType {
| `- note: 'T' previously declared here
374 |
375 | private var _groupId: String
:
417 | }
418 |
419 | struct GroupAssignment<T: KafkaMetadata>: KafkaType {
| `- warning: generic parameter 'T' shadows generic parameter from outer scope with the same name; this is an error in the Swift 6 language mode
420 |
421 | let memberId: String
/host/spi-builder-workspace/Sources/Franz/Broker.swift:491:39: error: cannot find type 'DispatchQueue' in scope
489 | private var _readQueues = [Int32: DispatchQueue]()
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
492 | return DispatchQueue(
493 | label: "metadata.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:498:40: error: cannot find type 'DispatchQueue' in scope
496 | }()
497 |
498 | private lazy var _metadataWriteQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
499 | return DispatchQueue(
500 | label: "metadata.write.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:505:36: error: cannot find type 'DispatchQueue' in scope
503 | }()
504 |
505 | private lazy var _adminReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
506 | return DispatchQueue(
507 | label: "admin.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:512:44: error: cannot find type 'DispatchQueue' in scope
510 | }()
511 |
512 | private lazy var _groupCoordinationQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
513 | return DispatchQueue(
514 | label: "group.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:489:36: error: cannot find 'DispatchQueue' in scope
487 | //MARK: Queues
488 |
489 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot find 'DispatchQueue' in scope
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:489:29: error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
487 | //MARK: Queues
488 |
489 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:489:28: error: cannot call value of non-function type '[AnyHashable : Any]'
487 | //MARK: Queues
488 |
489 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot call value of non-function type '[AnyHashable : Any]'
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
[11/32] Compiling Franz Consumer.swift
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:22:38: error: cannot find 'DispatchSemaphore' in scope
20 | internal var broker: Broker?
21 | internal var membership: GroupMembership?
22 | internal let joinedGroupSemaphore = DispatchSemaphore(value: 0)
| `- error: cannot find 'DispatchSemaphore' in scope
23 |
24 | var groupOffsetsTimer: Timer!
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:40:28: error: cannot find 'DispatchQueue' in scope
38 | }
39 |
40 | private let listenQueue = DispatchQueue(label: "FranzConsumerListenQueue")
| `- error: cannot find 'DispatchQueue' in scope
41 |
42 | var offsetsToCommit = [TopicName: [PartitionId: (Offset, OffsetMetadata?)]]()
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:43:3: error: Objective-C interoperability is disabled
41 |
42 | var offsetsToCommit = [TopicName: [PartitionId: (Offset, OffsetMetadata?)]]()
43 | @objc private func commitGroupoffsets() {
| `- error: Objective-C interoperability is disabled
44 | guard let groupId = self.membership?.group.id, let broker = self.broker else { return }
45 | broker.commitGroupOffset(groupId: groupId, topics: offsetsToCommit)
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:48:3: error: Objective-C interoperability is disabled
46 | }
47 |
48 | @objc private func sendHeartbeat() {
| `- error: Objective-C interoperability is disabled
49 | guard let groupId = self.membership?.group.id,
50 | let generationId = self.membership?.group.generationId,
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:35:86: error: '#selector' can only be used with the Objective-C runtime
33 | } else {
34 | // Fallback on earlier versions
35 | groupOffsetsTimer = Timer.scheduledTimer(timeInterval: 5, target: self, selector: #selector(commitGroupoffsets), userInfo: nil, repeats: true)
| `- error: '#selector' can only be used with the Objective-C runtime
36 | heartbeatTimer = Timer.scheduledTimer(timeInterval: 3, target: self, selector: #selector(sendHeartbeat), userInfo: nil, repeats: true)
37 | }
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:36:84: error: '#selector' can only be used with the Objective-C runtime
34 | // Fallback on earlier versions
35 | groupOffsetsTimer = Timer.scheduledTimer(timeInterval: 5, target: self, selector: #selector(commitGroupoffsets), userInfo: nil, repeats: true)
36 | heartbeatTimer = Timer.scheduledTimer(timeInterval: 3, target: self, selector: #selector(sendHeartbeat), userInfo: nil, repeats: true)
| `- error: '#selector' can only be used with the Objective-C runtime
37 | }
38 | }
/host/spi-builder-workspace/Sources/Franz/Crypt/CRC32.swift:145:9: warning: 'Hashable.hashValue' is deprecated as a protocol requirement; conform type 'CRC32' to 'Hashable' by implementing 'hash(into:)' instead [#DeprecatedDeclaration]
143 | private(set) var crc: UInt32 = 0
144 |
145 | var hashValue: Int {
| `- warning: 'Hashable.hashValue' is deprecated as a protocol requirement; conform type 'CRC32' to 'Hashable' by implementing 'hash(into:)' instead [#DeprecatedDeclaration]
146 | return Int(crc)
147 | }
/host/spi-builder-workspace/Sources/Franz/Group.swift:72:2: warning: 'internal(set)' modifier is redundant for an internal property
70 |
71 | var topics = Set<TopicName>()
72 | internal(set) var assignedPartitions = [TopicName: [PartitionId]]()
| `- warning: 'internal(set)' modifier is redundant for an internal property
73 | }
74 |
[#DeprecatedDeclaration]: <https://docs.swift.org/compiler/documentation/diagnostics/deprecated-declaration>
[12/32] Compiling Franz CRC32.swift
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:22:38: error: cannot find 'DispatchSemaphore' in scope
20 | internal var broker: Broker?
21 | internal var membership: GroupMembership?
22 | internal let joinedGroupSemaphore = DispatchSemaphore(value: 0)
| `- error: cannot find 'DispatchSemaphore' in scope
23 |
24 | var groupOffsetsTimer: Timer!
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:40:28: error: cannot find 'DispatchQueue' in scope
38 | }
39 |
40 | private let listenQueue = DispatchQueue(label: "FranzConsumerListenQueue")
| `- error: cannot find 'DispatchQueue' in scope
41 |
42 | var offsetsToCommit = [TopicName: [PartitionId: (Offset, OffsetMetadata?)]]()
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:43:3: error: Objective-C interoperability is disabled
41 |
42 | var offsetsToCommit = [TopicName: [PartitionId: (Offset, OffsetMetadata?)]]()
43 | @objc private func commitGroupoffsets() {
| `- error: Objective-C interoperability is disabled
44 | guard let groupId = self.membership?.group.id, let broker = self.broker else { return }
45 | broker.commitGroupOffset(groupId: groupId, topics: offsetsToCommit)
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:48:3: error: Objective-C interoperability is disabled
46 | }
47 |
48 | @objc private func sendHeartbeat() {
| `- error: Objective-C interoperability is disabled
49 | guard let groupId = self.membership?.group.id,
50 | let generationId = self.membership?.group.generationId,
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:35:86: error: '#selector' can only be used with the Objective-C runtime
33 | } else {
34 | // Fallback on earlier versions
35 | groupOffsetsTimer = Timer.scheduledTimer(timeInterval: 5, target: self, selector: #selector(commitGroupoffsets), userInfo: nil, repeats: true)
| `- error: '#selector' can only be used with the Objective-C runtime
36 | heartbeatTimer = Timer.scheduledTimer(timeInterval: 3, target: self, selector: #selector(sendHeartbeat), userInfo: nil, repeats: true)
37 | }
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:36:84: error: '#selector' can only be used with the Objective-C runtime
34 | // Fallback on earlier versions
35 | groupOffsetsTimer = Timer.scheduledTimer(timeInterval: 5, target: self, selector: #selector(commitGroupoffsets), userInfo: nil, repeats: true)
36 | heartbeatTimer = Timer.scheduledTimer(timeInterval: 3, target: self, selector: #selector(sendHeartbeat), userInfo: nil, repeats: true)
| `- error: '#selector' can only be used with the Objective-C runtime
37 | }
38 | }
/host/spi-builder-workspace/Sources/Franz/Crypt/CRC32.swift:145:9: warning: 'Hashable.hashValue' is deprecated as a protocol requirement; conform type 'CRC32' to 'Hashable' by implementing 'hash(into:)' instead [#DeprecatedDeclaration]
143 | private(set) var crc: UInt32 = 0
144 |
145 | var hashValue: Int {
| `- warning: 'Hashable.hashValue' is deprecated as a protocol requirement; conform type 'CRC32' to 'Hashable' by implementing 'hash(into:)' instead [#DeprecatedDeclaration]
146 | return Int(crc)
147 | }
/host/spi-builder-workspace/Sources/Franz/Group.swift:72:2: warning: 'internal(set)' modifier is redundant for an internal property
70 |
71 | var topics = Set<TopicName>()
72 | internal(set) var assignedPartitions = [TopicName: [PartitionId]]()
| `- warning: 'internal(set)' modifier is redundant for an internal property
73 | }
74 |
[#DeprecatedDeclaration]: <https://docs.swift.org/compiler/documentation/diagnostics/deprecated-declaration>
[13/32] Compiling Franz Enumerations.swift
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:22:38: error: cannot find 'DispatchSemaphore' in scope
20 | internal var broker: Broker?
21 | internal var membership: GroupMembership?
22 | internal let joinedGroupSemaphore = DispatchSemaphore(value: 0)
| `- error: cannot find 'DispatchSemaphore' in scope
23 |
24 | var groupOffsetsTimer: Timer!
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:40:28: error: cannot find 'DispatchQueue' in scope
38 | }
39 |
40 | private let listenQueue = DispatchQueue(label: "FranzConsumerListenQueue")
| `- error: cannot find 'DispatchQueue' in scope
41 |
42 | var offsetsToCommit = [TopicName: [PartitionId: (Offset, OffsetMetadata?)]]()
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:43:3: error: Objective-C interoperability is disabled
41 |
42 | var offsetsToCommit = [TopicName: [PartitionId: (Offset, OffsetMetadata?)]]()
43 | @objc private func commitGroupoffsets() {
| `- error: Objective-C interoperability is disabled
44 | guard let groupId = self.membership?.group.id, let broker = self.broker else { return }
45 | broker.commitGroupOffset(groupId: groupId, topics: offsetsToCommit)
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:48:3: error: Objective-C interoperability is disabled
46 | }
47 |
48 | @objc private func sendHeartbeat() {
| `- error: Objective-C interoperability is disabled
49 | guard let groupId = self.membership?.group.id,
50 | let generationId = self.membership?.group.generationId,
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:35:86: error: '#selector' can only be used with the Objective-C runtime
33 | } else {
34 | // Fallback on earlier versions
35 | groupOffsetsTimer = Timer.scheduledTimer(timeInterval: 5, target: self, selector: #selector(commitGroupoffsets), userInfo: nil, repeats: true)
| `- error: '#selector' can only be used with the Objective-C runtime
36 | heartbeatTimer = Timer.scheduledTimer(timeInterval: 3, target: self, selector: #selector(sendHeartbeat), userInfo: nil, repeats: true)
37 | }
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:36:84: error: '#selector' can only be used with the Objective-C runtime
34 | // Fallback on earlier versions
35 | groupOffsetsTimer = Timer.scheduledTimer(timeInterval: 5, target: self, selector: #selector(commitGroupoffsets), userInfo: nil, repeats: true)
36 | heartbeatTimer = Timer.scheduledTimer(timeInterval: 3, target: self, selector: #selector(sendHeartbeat), userInfo: nil, repeats: true)
| `- error: '#selector' can only be used with the Objective-C runtime
37 | }
38 | }
/host/spi-builder-workspace/Sources/Franz/Crypt/CRC32.swift:145:9: warning: 'Hashable.hashValue' is deprecated as a protocol requirement; conform type 'CRC32' to 'Hashable' by implementing 'hash(into:)' instead [#DeprecatedDeclaration]
143 | private(set) var crc: UInt32 = 0
144 |
145 | var hashValue: Int {
| `- warning: 'Hashable.hashValue' is deprecated as a protocol requirement; conform type 'CRC32' to 'Hashable' by implementing 'hash(into:)' instead [#DeprecatedDeclaration]
146 | return Int(crc)
147 | }
/host/spi-builder-workspace/Sources/Franz/Group.swift:72:2: warning: 'internal(set)' modifier is redundant for an internal property
70 |
71 | var topics = Set<TopicName>()
72 | internal(set) var assignedPartitions = [TopicName: [PartitionId]]()
| `- warning: 'internal(set)' modifier is redundant for an internal property
73 | }
74 |
[#DeprecatedDeclaration]: <https://docs.swift.org/compiler/documentation/diagnostics/deprecated-declaration>
[14/32] Compiling Franz Group.swift
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:22:38: error: cannot find 'DispatchSemaphore' in scope
20 | internal var broker: Broker?
21 | internal var membership: GroupMembership?
22 | internal let joinedGroupSemaphore = DispatchSemaphore(value: 0)
| `- error: cannot find 'DispatchSemaphore' in scope
23 |
24 | var groupOffsetsTimer: Timer!
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:40:28: error: cannot find 'DispatchQueue' in scope
38 | }
39 |
40 | private let listenQueue = DispatchQueue(label: "FranzConsumerListenQueue")
| `- error: cannot find 'DispatchQueue' in scope
41 |
42 | var offsetsToCommit = [TopicName: [PartitionId: (Offset, OffsetMetadata?)]]()
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:43:3: error: Objective-C interoperability is disabled
41 |
42 | var offsetsToCommit = [TopicName: [PartitionId: (Offset, OffsetMetadata?)]]()
43 | @objc private func commitGroupoffsets() {
| `- error: Objective-C interoperability is disabled
44 | guard let groupId = self.membership?.group.id, let broker = self.broker else { return }
45 | broker.commitGroupOffset(groupId: groupId, topics: offsetsToCommit)
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:48:3: error: Objective-C interoperability is disabled
46 | }
47 |
48 | @objc private func sendHeartbeat() {
| `- error: Objective-C interoperability is disabled
49 | guard let groupId = self.membership?.group.id,
50 | let generationId = self.membership?.group.generationId,
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:35:86: error: '#selector' can only be used with the Objective-C runtime
33 | } else {
34 | // Fallback on earlier versions
35 | groupOffsetsTimer = Timer.scheduledTimer(timeInterval: 5, target: self, selector: #selector(commitGroupoffsets), userInfo: nil, repeats: true)
| `- error: '#selector' can only be used with the Objective-C runtime
36 | heartbeatTimer = Timer.scheduledTimer(timeInterval: 3, target: self, selector: #selector(sendHeartbeat), userInfo: nil, repeats: true)
37 | }
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:36:84: error: '#selector' can only be used with the Objective-C runtime
34 | // Fallback on earlier versions
35 | groupOffsetsTimer = Timer.scheduledTimer(timeInterval: 5, target: self, selector: #selector(commitGroupoffsets), userInfo: nil, repeats: true)
36 | heartbeatTimer = Timer.scheduledTimer(timeInterval: 3, target: self, selector: #selector(sendHeartbeat), userInfo: nil, repeats: true)
| `- error: '#selector' can only be used with the Objective-C runtime
37 | }
38 | }
/host/spi-builder-workspace/Sources/Franz/Crypt/CRC32.swift:145:9: warning: 'Hashable.hashValue' is deprecated as a protocol requirement; conform type 'CRC32' to 'Hashable' by implementing 'hash(into:)' instead [#DeprecatedDeclaration]
143 | private(set) var crc: UInt32 = 0
144 |
145 | var hashValue: Int {
| `- warning: 'Hashable.hashValue' is deprecated as a protocol requirement; conform type 'CRC32' to 'Hashable' by implementing 'hash(into:)' instead [#DeprecatedDeclaration]
146 | return Int(crc)
147 | }
/host/spi-builder-workspace/Sources/Franz/Group.swift:72:2: warning: 'internal(set)' modifier is redundant for an internal property
70 |
71 | var topics = Set<TopicName>()
72 | internal(set) var assignedPartitions = [TopicName: [PartitionId]]()
| `- warning: 'internal(set)' modifier is redundant for an internal property
73 | }
74 |
[#DeprecatedDeclaration]: <https://docs.swift.org/compiler/documentation/diagnostics/deprecated-declaration>
[15/32] Compiling Franz APIVersionsAPI.swift
[16/32] Compiling Franz AdminAPI.swift
[17/32] Compiling Franz CreateTopicsAPI.swift
[18/32] Compiling Franz FetchAPI.swift
[19/32] Compiling Franz MessageSet.swift
/host/spi-builder-workspace/Sources/Franz/MessageSet.swift:12:2: error: Objective-C interoperability is disabled
10 |
11 |
12 | @objc public class MessageSet: NSObject, KafkaType {
| `- error: Objective-C interoperability is disabled
13 | let values: [MessageSetItem]
14 |
/host/spi-builder-workspace/Sources/Franz/MessageSet.swift:168:2: error: Objective-C interoperability is disabled
166 | */
167 | //TODO: Convert to struct
168 | @objc public class Message: NSObject {
| `- error: Objective-C interoperability is disabled
169 |
170 | /**
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:13:2: error: Objective-C interoperability is disabled
11 | Base consumer delegate. Used by SimpleConsumer.
12 | */
13 | @objc public protocol ConsumerDelegate {
| `- error: Objective-C interoperability is disabled
14 | /**
15 | Called when the consumer has consumed a new Message
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:31:8: error: 'optional' can only be applied to members of an '@objc' protocol
29 | - Parameter errorDescription: a description of the error returned from the server
30 | */
31 | @objc optional func fetchDidFail(
| `- error: 'optional' can only be applied to members of an '@objc' protocol
32 | _ topic: String,
33 | partition: Int32,
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:31:3: error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
29 | - Parameter errorDescription: a description of the error returned from the server
30 | */
31 | @objc optional func fetchDidFail(
| `- error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
32 | _ topic: String,
33 | partition: Int32,
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:49:8: error: 'optional' can only be applied to members of an '@objc' protocol
47 | - Returns: true if broker should attempt to retry request, false if not
48 | */
49 | @objc optional func shouldRetryFailedFetch(
| `- error: 'optional' can only be applied to members of an '@objc' protocol
50 | _ topic: String,
51 | partition: Int32,
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:49:3: error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
47 | - Returns: true if broker should attempt to retry request, false if not
48 | */
49 | @objc optional func shouldRetryFailedFetch(
| `- error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
50 | _ topic: String,
51 | partition: Int32,
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:69:8: error: 'optional' can only be applied to members of an '@objc' protocol
67 | - Parameter partition: the partition
68 | */
69 | @objc optional func topicPartitionLeaderNotFound(_ topic: String, partition: Int32)
| `- error: 'optional' can only be applied to members of an '@objc' protocol
70 | }
71 |
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:69:3: error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
67 | - Parameter partition: the partition
68 | */
69 | @objc optional func topicPartitionLeaderNotFound(_ topic: String, partition: Int32)
| `- error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
70 | }
71 |
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:76:2: error: Objective-C interoperability is disabled
74 | High-level consumer delegate. Used by HighLevelConsumer.
75 | */
76 | @objc public protocol HighLevelConsumerDelegate: ConsumerDelegate {
| `- error: Objective-C interoperability is disabled
77 | /**
78 | Called after messages have been pulled for server.
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:86:8: error: 'optional' can only be applied to members of an '@objc' protocol
84 | - Returns: true if offset should be committed, false if otherwise
85 | */
86 | @objc optional func shouldCommitOffset(_ topic: String, partition: Int32, offset: Int64) -> Bool
| `- error: 'optional' can only be applied to members of an '@objc' protocol
87 |
88 | /**
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:86:3: error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
84 | - Returns: true if offset should be committed, false if otherwise
85 | */
86 | @objc optional func shouldCommitOffset(_ topic: String, partition: Int32, offset: Int64) -> Bool
| `- error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
87 |
88 | /**
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:97:8: error: 'optional' can only be applied to members of an '@objc' protocol
95 | - Returns: additional metadata to send with offset commit to server
96 | */
97 | @objc optional func shouldAttachOffsetMetadata(_ topic: String, partition: Int32, offset: Int64) -> String?
| `- error: 'optional' can only be applied to members of an '@objc' protocol
98 |
99 | /**
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:97:3: error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
95 | - Returns: additional metadata to send with offset commit to server
96 | */
97 | @objc optional func shouldAttachOffsetMetadata(_ topic: String, partition: Int32, offset: Int64) -> String?
| `- error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
98 |
99 | /**
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:106:8: error: 'optional' can only be applied to members of an '@objc' protocol
104 | - Parameter offset: the offset
105 | */
106 | @objc optional func offsetDidCommit(_ topic: String, partition: Int32, offset: Int64)
| `- error: 'optional' can only be applied to members of an '@objc' protocol
107 |
108 | /**
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:106:3: error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
104 | - Parameter offset: the offset
105 | */
106 | @objc optional func offsetDidCommit(_ topic: String, partition: Int32, offset: Int64)
| `- error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
107 |
108 | /**
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:117:8: error: 'optional' can only be applied to members of an '@objc' protocol
115 | - Parameter errorDescription: description of the error
116 | */
117 | @objc optional func offsetCommitDidFail(_ topic: String, partition: Int32, offset: Int64, errorId: Int16, errorDescription: String)
| `- error: 'optional' can only be applied to members of an '@objc' protocol
118 |
119 | /**
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:117:3: error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
115 | - Parameter errorDescription: description of the error
116 | */
117 | @objc optional func offsetCommitDidFail(_ topic: String, partition: Int32, offset: Int64, errorId: Int16, errorDescription: String)
| `- error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
118 |
119 | /**
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:130:8: error: 'optional' can only be applied to members of an '@objc' protocol
128 | - Returns: true if offset commit should be retried, false if otherwise
129 | */
130 | @objc optional func shouldRetryFailedOffsetCommit(_ topic: String, partition: Int32, offset: Int64, errorId: Int16, errorDescription: String) -> Bool
| `- error: 'optional' can only be applied to members of an '@objc' protocol
131 | }
132 |
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:130:3: error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
128 | - Returns: true if offset commit should be retried, false if otherwise
129 | */
130 | @objc optional func shouldRetryFailedOffsetCommit(_ topic: String, partition: Int32, offset: Int64, errorId: Int16, errorDescription: String) -> Bool
| `- error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
131 | }
132 |
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:189:65: error: cannot use optional chaining on non-optional value of type '(String, Int32, Int16, String) -> Bool'
187 | print("Failed polling with a non-kafka error")
188 | case .kafkaError(let errorCode):
189 | if errorCode.retriable, self.delegate.shouldRetryFailedFetch?(self._topic, partition: self._partition, errorId: errorCode.code, errorDescription: errorCode.description) ?? true {
| `- error: cannot use optional chaining on non-optional value of type '(String, Int32, Int16, String) -> Bool'
190 | self.poll(offset)
191 | }
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:244:85: error: cannot force unwrap value of non-optional type '(String, Int32, Int64) -> Bool'
242 | }
243 |
244 | guard self.delegate.shouldCommitOffset != nil && self.delegate.shouldCommitOffset!(self._topic, partition: self._partition, offset: offset) else {
| `- error: cannot force unwrap value of non-optional type '(String, Int32, Int64) -> Bool'
245 | return
246 | }
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:258:65: error: cannot use optional chaining on non-optional value of type '(String, Int32, Int16, String) -> Bool'
256 | print("Failed polling with a non-kafka error")
257 | case .kafkaError(let errorCode):
258 | if errorCode.retriable, self.delegate.shouldRetryFailedFetch?(self._topic, partition: self._partition, errorId: errorCode.code, errorDescription: errorCode.description) ?? true {
| `- error: cannot use optional chaining on non-optional value of type '(String, Int32, Int16, String) -> Bool'
259 | self.poll()
260 | }
[20/32] Compiling Franz OldConsumers.swift
/host/spi-builder-workspace/Sources/Franz/MessageSet.swift:12:2: error: Objective-C interoperability is disabled
10 |
11 |
12 | @objc public class MessageSet: NSObject, KafkaType {
| `- error: Objective-C interoperability is disabled
13 | let values: [MessageSetItem]
14 |
/host/spi-builder-workspace/Sources/Franz/MessageSet.swift:168:2: error: Objective-C interoperability is disabled
166 | */
167 | //TODO: Convert to struct
168 | @objc public class Message: NSObject {
| `- error: Objective-C interoperability is disabled
169 |
170 | /**
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:13:2: error: Objective-C interoperability is disabled
11 | Base consumer delegate. Used by SimpleConsumer.
12 | */
13 | @objc public protocol ConsumerDelegate {
| `- error: Objective-C interoperability is disabled
14 | /**
15 | Called when the consumer has consumed a new Message
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:31:8: error: 'optional' can only be applied to members of an '@objc' protocol
29 | - Parameter errorDescription: a description of the error returned from the server
30 | */
31 | @objc optional func fetchDidFail(
| `- error: 'optional' can only be applied to members of an '@objc' protocol
32 | _ topic: String,
33 | partition: Int32,
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:31:3: error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
29 | - Parameter errorDescription: a description of the error returned from the server
30 | */
31 | @objc optional func fetchDidFail(
| `- error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
32 | _ topic: String,
33 | partition: Int32,
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:49:8: error: 'optional' can only be applied to members of an '@objc' protocol
47 | - Returns: true if broker should attempt to retry request, false if not
48 | */
49 | @objc optional func shouldRetryFailedFetch(
| `- error: 'optional' can only be applied to members of an '@objc' protocol
50 | _ topic: String,
51 | partition: Int32,
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:49:3: error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
47 | - Returns: true if broker should attempt to retry request, false if not
48 | */
49 | @objc optional func shouldRetryFailedFetch(
| `- error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
50 | _ topic: String,
51 | partition: Int32,
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:69:8: error: 'optional' can only be applied to members of an '@objc' protocol
67 | - Parameter partition: the partition
68 | */
69 | @objc optional func topicPartitionLeaderNotFound(_ topic: String, partition: Int32)
| `- error: 'optional' can only be applied to members of an '@objc' protocol
70 | }
71 |
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:69:3: error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
67 | - Parameter partition: the partition
68 | */
69 | @objc optional func topicPartitionLeaderNotFound(_ topic: String, partition: Int32)
| `- error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
70 | }
71 |
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:76:2: error: Objective-C interoperability is disabled
74 | High-level consumer delegate. Used by HighLevelConsumer.
75 | */
76 | @objc public protocol HighLevelConsumerDelegate: ConsumerDelegate {
| `- error: Objective-C interoperability is disabled
77 | /**
78 | Called after messages have been pulled for server.
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:86:8: error: 'optional' can only be applied to members of an '@objc' protocol
84 | - Returns: true if offset should be committed, false if otherwise
85 | */
86 | @objc optional func shouldCommitOffset(_ topic: String, partition: Int32, offset: Int64) -> Bool
| `- error: 'optional' can only be applied to members of an '@objc' protocol
87 |
88 | /**
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:86:3: error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
84 | - Returns: true if offset should be committed, false if otherwise
85 | */
86 | @objc optional func shouldCommitOffset(_ topic: String, partition: Int32, offset: Int64) -> Bool
| `- error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
87 |
88 | /**
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:97:8: error: 'optional' can only be applied to members of an '@objc' protocol
95 | - Returns: additional metadata to send with offset commit to server
96 | */
97 | @objc optional func shouldAttachOffsetMetadata(_ topic: String, partition: Int32, offset: Int64) -> String?
| `- error: 'optional' can only be applied to members of an '@objc' protocol
98 |
99 | /**
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:97:3: error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
95 | - Returns: additional metadata to send with offset commit to server
96 | */
97 | @objc optional func shouldAttachOffsetMetadata(_ topic: String, partition: Int32, offset: Int64) -> String?
| `- error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
98 |
99 | /**
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:106:8: error: 'optional' can only be applied to members of an '@objc' protocol
104 | - Parameter offset: the offset
105 | */
106 | @objc optional func offsetDidCommit(_ topic: String, partition: Int32, offset: Int64)
| `- error: 'optional' can only be applied to members of an '@objc' protocol
107 |
108 | /**
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:106:3: error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
104 | - Parameter offset: the offset
105 | */
106 | @objc optional func offsetDidCommit(_ topic: String, partition: Int32, offset: Int64)
| `- error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
107 |
108 | /**
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:117:8: error: 'optional' can only be applied to members of an '@objc' protocol
115 | - Parameter errorDescription: description of the error
116 | */
117 | @objc optional func offsetCommitDidFail(_ topic: String, partition: Int32, offset: Int64, errorId: Int16, errorDescription: String)
| `- error: 'optional' can only be applied to members of an '@objc' protocol
118 |
119 | /**
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:117:3: error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
115 | - Parameter errorDescription: description of the error
116 | */
117 | @objc optional func offsetCommitDidFail(_ topic: String, partition: Int32, offset: Int64, errorId: Int16, errorDescription: String)
| `- error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
118 |
119 | /**
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:130:8: error: 'optional' can only be applied to members of an '@objc' protocol
128 | - Returns: true if offset commit should be retried, false if otherwise
129 | */
130 | @objc optional func shouldRetryFailedOffsetCommit(_ topic: String, partition: Int32, offset: Int64, errorId: Int16, errorDescription: String) -> Bool
| `- error: 'optional' can only be applied to members of an '@objc' protocol
131 | }
132 |
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:130:3: error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
128 | - Returns: true if offset commit should be retried, false if otherwise
129 | */
130 | @objc optional func shouldRetryFailedOffsetCommit(_ topic: String, partition: Int32, offset: Int64, errorId: Int16, errorDescription: String) -> Bool
| `- error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
131 | }
132 |
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:189:65: error: cannot use optional chaining on non-optional value of type '(String, Int32, Int16, String) -> Bool'
187 | print("Failed polling with a non-kafka error")
188 | case .kafkaError(let errorCode):
189 | if errorCode.retriable, self.delegate.shouldRetryFailedFetch?(self._topic, partition: self._partition, errorId: errorCode.code, errorDescription: errorCode.description) ?? true {
| `- error: cannot use optional chaining on non-optional value of type '(String, Int32, Int16, String) -> Bool'
190 | self.poll(offset)
191 | }
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:244:85: error: cannot force unwrap value of non-optional type '(String, Int32, Int64) -> Bool'
242 | }
243 |
244 | guard self.delegate.shouldCommitOffset != nil && self.delegate.shouldCommitOffset!(self._topic, partition: self._partition, offset: offset) else {
| `- error: cannot force unwrap value of non-optional type '(String, Int32, Int64) -> Bool'
245 | return
246 | }
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:258:65: error: cannot use optional chaining on non-optional value of type '(String, Int32, Int16, String) -> Bool'
256 | print("Failed polling with a non-kafka error")
257 | case .kafkaError(let errorCode):
258 | if errorCode.retriable, self.delegate.shouldRetryFailedFetch?(self._topic, partition: self._partition, errorId: errorCode.code, errorDescription: errorCode.description) ?? true {
| `- error: cannot use optional chaining on non-optional value of type '(String, Int32, Int16, String) -> Bool'
259 | self.poll()
260 | }
[21/32] Compiling Franz Partition.swift
/host/spi-builder-workspace/Sources/Franz/MessageSet.swift:12:2: error: Objective-C interoperability is disabled
10 |
11 |
12 | @objc public class MessageSet: NSObject, KafkaType {
| `- error: Objective-C interoperability is disabled
13 | let values: [MessageSetItem]
14 |
/host/spi-builder-workspace/Sources/Franz/MessageSet.swift:168:2: error: Objective-C interoperability is disabled
166 | */
167 | //TODO: Convert to struct
168 | @objc public class Message: NSObject {
| `- error: Objective-C interoperability is disabled
169 |
170 | /**
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:13:2: error: Objective-C interoperability is disabled
11 | Base consumer delegate. Used by SimpleConsumer.
12 | */
13 | @objc public protocol ConsumerDelegate {
| `- error: Objective-C interoperability is disabled
14 | /**
15 | Called when the consumer has consumed a new Message
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:31:8: error: 'optional' can only be applied to members of an '@objc' protocol
29 | - Parameter errorDescription: a description of the error returned from the server
30 | */
31 | @objc optional func fetchDidFail(
| `- error: 'optional' can only be applied to members of an '@objc' protocol
32 | _ topic: String,
33 | partition: Int32,
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:31:3: error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
29 | - Parameter errorDescription: a description of the error returned from the server
30 | */
31 | @objc optional func fetchDidFail(
| `- error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
32 | _ topic: String,
33 | partition: Int32,
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:49:8: error: 'optional' can only be applied to members of an '@objc' protocol
47 | - Returns: true if broker should attempt to retry request, false if not
48 | */
49 | @objc optional func shouldRetryFailedFetch(
| `- error: 'optional' can only be applied to members of an '@objc' protocol
50 | _ topic: String,
51 | partition: Int32,
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:49:3: error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
47 | - Returns: true if broker should attempt to retry request, false if not
48 | */
49 | @objc optional func shouldRetryFailedFetch(
| `- error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
50 | _ topic: String,
51 | partition: Int32,
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:69:8: error: 'optional' can only be applied to members of an '@objc' protocol
67 | - Parameter partition: the partition
68 | */
69 | @objc optional func topicPartitionLeaderNotFound(_ topic: String, partition: Int32)
| `- error: 'optional' can only be applied to members of an '@objc' protocol
70 | }
71 |
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:69:3: error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
67 | - Parameter partition: the partition
68 | */
69 | @objc optional func topicPartitionLeaderNotFound(_ topic: String, partition: Int32)
| `- error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
70 | }
71 |
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:76:2: error: Objective-C interoperability is disabled
74 | High-level consumer delegate. Used by HighLevelConsumer.
75 | */
76 | @objc public protocol HighLevelConsumerDelegate: ConsumerDelegate {
| `- error: Objective-C interoperability is disabled
77 | /**
78 | Called after messages have been pulled for server.
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:86:8: error: 'optional' can only be applied to members of an '@objc' protocol
84 | - Returns: true if offset should be committed, false if otherwise
85 | */
86 | @objc optional func shouldCommitOffset(_ topic: String, partition: Int32, offset: Int64) -> Bool
| `- error: 'optional' can only be applied to members of an '@objc' protocol
87 |
88 | /**
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:86:3: error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
84 | - Returns: true if offset should be committed, false if otherwise
85 | */
86 | @objc optional func shouldCommitOffset(_ topic: String, partition: Int32, offset: Int64) -> Bool
| `- error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
87 |
88 | /**
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:97:8: error: 'optional' can only be applied to members of an '@objc' protocol
95 | - Returns: additional metadata to send with offset commit to server
96 | */
97 | @objc optional func shouldAttachOffsetMetadata(_ topic: String, partition: Int32, offset: Int64) -> String?
| `- error: 'optional' can only be applied to members of an '@objc' protocol
98 |
99 | /**
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:97:3: error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
95 | - Returns: additional metadata to send with offset commit to server
96 | */
97 | @objc optional func shouldAttachOffsetMetadata(_ topic: String, partition: Int32, offset: Int64) -> String?
| `- error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
98 |
99 | /**
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:106:8: error: 'optional' can only be applied to members of an '@objc' protocol
104 | - Parameter offset: the offset
105 | */
106 | @objc optional func offsetDidCommit(_ topic: String, partition: Int32, offset: Int64)
| `- error: 'optional' can only be applied to members of an '@objc' protocol
107 |
108 | /**
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:106:3: error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
104 | - Parameter offset: the offset
105 | */
106 | @objc optional func offsetDidCommit(_ topic: String, partition: Int32, offset: Int64)
| `- error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
107 |
108 | /**
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:117:8: error: 'optional' can only be applied to members of an '@objc' protocol
115 | - Parameter errorDescription: description of the error
116 | */
117 | @objc optional func offsetCommitDidFail(_ topic: String, partition: Int32, offset: Int64, errorId: Int16, errorDescription: String)
| `- error: 'optional' can only be applied to members of an '@objc' protocol
118 |
119 | /**
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:117:3: error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
115 | - Parameter errorDescription: description of the error
116 | */
117 | @objc optional func offsetCommitDidFail(_ topic: String, partition: Int32, offset: Int64, errorId: Int16, errorDescription: String)
| `- error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
118 |
119 | /**
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:130:8: error: 'optional' can only be applied to members of an '@objc' protocol
128 | - Returns: true if offset commit should be retried, false if otherwise
129 | */
130 | @objc optional func shouldRetryFailedOffsetCommit(_ topic: String, partition: Int32, offset: Int64, errorId: Int16, errorDescription: String) -> Bool
| `- error: 'optional' can only be applied to members of an '@objc' protocol
131 | }
132 |
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:130:3: error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
128 | - Returns: true if offset commit should be retried, false if otherwise
129 | */
130 | @objc optional func shouldRetryFailedOffsetCommit(_ topic: String, partition: Int32, offset: Int64, errorId: Int16, errorDescription: String) -> Bool
| `- error: '@objc' can only be used with members of classes, '@objc' protocols, and concrete extensions of classes
131 | }
132 |
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:189:65: error: cannot use optional chaining on non-optional value of type '(String, Int32, Int16, String) -> Bool'
187 | print("Failed polling with a non-kafka error")
188 | case .kafkaError(let errorCode):
189 | if errorCode.retriable, self.delegate.shouldRetryFailedFetch?(self._topic, partition: self._partition, errorId: errorCode.code, errorDescription: errorCode.description) ?? true {
| `- error: cannot use optional chaining on non-optional value of type '(String, Int32, Int16, String) -> Bool'
190 | self.poll(offset)
191 | }
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:244:85: error: cannot force unwrap value of non-optional type '(String, Int32, Int64) -> Bool'
242 | }
243 |
244 | guard self.delegate.shouldCommitOffset != nil && self.delegate.shouldCommitOffset!(self._topic, partition: self._partition, offset: offset) else {
| `- error: cannot force unwrap value of non-optional type '(String, Int32, Int64) -> Bool'
245 | return
246 | }
/host/spi-builder-workspace/Sources/Franz/OldConsumers.swift:258:65: error: cannot use optional chaining on non-optional value of type '(String, Int32, Int16, String) -> Bool'
256 | print("Failed polling with a non-kafka error")
257 | case .kafkaError(let errorCode):
258 | if errorCode.retriable, self.delegate.shouldRetryFailedFetch?(self._topic, partition: self._partition, errorId: errorCode.code, errorDescription: errorCode.description) ?? true {
| `- error: cannot use optional chaining on non-optional value of type '(String, Int32, Int16, String) -> Bool'
259 | self.poll()
260 | }
[22/32] Compiling Franz Assignment.swift
/host/spi-builder-workspace/Sources/Franz/Broker.swift:491:39: error: cannot find type 'DispatchQueue' in scope
489 | private var _readQueues = [Int32: DispatchQueue]()
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
492 | return DispatchQueue(
493 | label: "metadata.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:498:40: error: cannot find type 'DispatchQueue' in scope
496 | }()
497 |
498 | private lazy var _metadataWriteQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
499 | return DispatchQueue(
500 | label: "metadata.write.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:505:36: error: cannot find type 'DispatchQueue' in scope
503 | }()
504 |
505 | private lazy var _adminReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
506 | return DispatchQueue(
507 | label: "admin.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:512:44: error: cannot find type 'DispatchQueue' in scope
510 | }()
511 |
512 | private lazy var _groupCoordinationQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
513 | return DispatchQueue(
514 | label: "group.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:472:69: error: cannot find type 'DispatchQueue' in scope
470 | }
471 |
472 | private func getReadQueue(_ topic: String, partition: Int32) -> DispatchQueue {
| `- error: cannot find type 'DispatchQueue' in scope
473 | var readQueue: DispatchQueue
474 | if let pq = _readQueues[partition] {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:489:36: error: cannot find 'DispatchQueue' in scope
487 | //MARK: Queues
488 |
489 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot find 'DispatchQueue' in scope
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:489:28: error: cannot call value of non-function type '[AnyHashable : Any]'
487 | //MARK: Queues
488 |
489 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot call value of non-function type '[AnyHashable : Any]'
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:489:29: error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
487 | //MARK: Queues
488 |
489 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:492:10: error: cannot find 'DispatchQueue' in scope
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
492 | return DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
493 | label: "metadata.read.stream.franz",
494 | attributes: []
/host/spi-builder-workspace/Sources/Franz/Broker.swift:499:10: error: cannot find 'DispatchQueue' in scope
497 |
498 | private lazy var _metadataWriteQueue: DispatchQueue = {
499 | return DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
500 | label: "metadata.write.stream.franz",
501 | attributes: []
/host/spi-builder-workspace/Sources/Franz/Broker.swift:506:10: error: cannot find 'DispatchQueue' in scope
504 |
505 | private lazy var _adminReadQueue: DispatchQueue = {
506 | return DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
507 | label: "admin.read.stream.franz",
508 | attributes: []
/host/spi-builder-workspace/Sources/Franz/Broker.swift:513:10: error: cannot find 'DispatchQueue' in scope
511 |
512 | private lazy var _groupCoordinationQueue: DispatchQueue = {
513 | return DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
514 | label: "group.read.stream.franz",
515 | attributes: []
/host/spi-builder-workspace/Sources/Franz/Broker.swift:189:54: error: cannot call value of non-function type 'Date'
187 | case .rebalanceInProgressCode:
188 | print("Rebalance in progress, retrying offset commit after 1 second")
189 | self._metadataReadQueue.asyncAfter(deadline: .now() + 1) {
| `- error: cannot call value of non-function type 'Date'
190 | self.commitGroupOffset(groupId: groupId, topics: topics)
191 | }
/host/spi-builder-workspace/Sources/Franz/Broker.swift:473:24: error: cannot find type 'DispatchQueue' in scope
471 |
472 | private func getReadQueue(_ topic: String, partition: Int32) -> DispatchQueue {
473 | var readQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
474 | if let pq = _readQueues[partition] {
475 | readQueue = pq
/host/spi-builder-workspace/Sources/Franz/Broker.swift:477:38: error: cannot find 'DispatchQueue' in scope
475 | readQueue = pq
476 | } else {
477 | _readQueues[partition] = DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
478 | label: "\(partition).\(topic).read.stream.franz",
479 | attributes: DispatchQueue.Attributes.concurrent
/host/spi-builder-workspace/Sources/Franz/Broker.swift:479:29: error: cannot find 'DispatchQueue' in scope
477 | _readQueues[partition] = DispatchQueue(
478 | label: "\(partition).\(topic).read.stream.franz",
479 | attributes: DispatchQueue.Attributes.concurrent
| `- error: cannot find 'DispatchQueue' in scope
480 | )
481 | readQueue = _readQueues[partition]!
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:35:29: error: cannot find type 'DispatchQueue' in scope
33 | let nodeId: ReplicaId
34 |
35 | lazy var dispatchQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
36 | return DispatchQueue(label: "metadata.cluster.read.stream.franz")
37 | }()
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:36:16: error: cannot find 'DispatchQueue' in scope
34 |
35 | lazy var dispatchQueue: DispatchQueue = {
36 | return DispatchQueue(label: "metadata.cluster.read.stream.franz")
| `- error: cannot find 'DispatchQueue' in scope
37 | }()
38 |
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:404:33: error: cannot find 'DispatchWorkItem' in scope
402 |
403 | for (_, broker) in brokers {
404 | let dispatchBlock = DispatchWorkItem(qos: .unspecified, flags: []) {
| `- error: cannot find 'DispatchWorkItem' in scope
405 |
406 | var handleGetTopicMetadata: ((MetadataResponse) -> Void)!
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:414:29: error: cannot find 'Thread' in scope
412 | let retryTopics = response.topics.filter { key, val in val.error == .leaderNotAvailable }.compactMap { $1.name }
413 | print("Leader not available, trying to find leader again in 1 second")
414 | Thread.sleep(forTimeInterval: 1)
| `- error: cannot find 'Thread' in scope
415 | broker.getTopicMetadata(topics: retryTopics, completion: handleGetTopicMetadata)
416 | return
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:404:56: error: cannot infer contextual base in reference to member 'unspecified'
402 |
403 | for (_, broker) in brokers {
404 | let dispatchBlock = DispatchWorkItem(qos: .unspecified, flags: []) {
| `- error: cannot infer contextual base in reference to member 'unspecified'
405 |
406 | var handleGetTopicMetadata: ((MetadataResponse) -> Void)!
/host/spi-builder-workspace/Sources/Franz/Connection.swift:89:39: error: cannot find type 'CFReadStream' in scope
87 | private var clientId: String
88 |
89 | private var readStream: Unmanaged<CFReadStream>?
| `- error: cannot find type 'CFReadStream' in scope
90 | private var writeStream: Unmanaged<CFWriteStream>?
91 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:90:40: error: cannot find type 'CFWriteStream' in scope
88 |
89 | private var readStream: Unmanaged<CFReadStream>?
90 | private var writeStream: Unmanaged<CFWriteStream>?
| `- error: cannot find type 'CFWriteStream' in scope
91 |
92 | private var inputStream: InputStream?
/host/spi-builder-workspace/Sources/Franz/Connection.swift:98:35: error: cannot find type 'DispatchQueue' in scope
96 | private let responseCorrelationIdSize: Int32 = 4
97 |
98 | private var inputStreamQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
99 | private var outputStreamQueue: DispatchQueue
100 | private var writeRequestBlocks = [()->()]()
/host/spi-builder-workspace/Sources/Franz/Connection.swift:99:36: error: cannot find type 'DispatchQueue' in scope
97 |
98 | private var inputStreamQueue: DispatchQueue
99 | private var outputStreamQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
100 | private var writeRequestBlocks = [()->()]()
101 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:116:28: error: cannot find 'DispatchQueue' in scope
114 | self.port = config.port
115 |
116 | inputStreamQueue = DispatchQueue(label: "\(self.host).\(self.port).input.stream.franz")
| `- error: cannot find 'DispatchQueue' in scope
117 | outputStreamQueue = DispatchQueue(label: "\(self.host).\(self.port).output.stream.franz")
118 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:117:23: error: cannot find 'DispatchQueue' in scope
115 |
116 | inputStreamQueue = DispatchQueue(label: "\(self.host).\(self.port).input.stream.franz")
117 | outputStreamQueue = DispatchQueue(label: "\(self.host).\(self.port).output.stream.franz")
| `- error: cannot find 'DispatchQueue' in scope
118 |
119 | super.init()
/host/spi-builder-workspace/Sources/Franz/Connection.swift:121:9: error: cannot find 'CFStreamCreatePairWithSocketToHost' in scope
119 | super.init()
120 |
121 | CFStreamCreatePairWithSocketToHost(
| `- error: cannot find 'CFStreamCreatePairWithSocketToHost' in scope
122 | kCFAllocatorDefault,
123 | host as CFString,
/host/spi-builder-workspace/Sources/Franz/Connection.swift:122:13: error: cannot find 'kCFAllocatorDefault' in scope
120 |
121 | CFStreamCreatePairWithSocketToHost(
122 | kCFAllocatorDefault,
| `- error: cannot find 'kCFAllocatorDefault' in scope
123 | host as CFString,
124 | UInt32(port),
/host/spi-builder-workspace/Sources/Franz/Connection.swift:123:21: error: cannot find type 'CFString' in scope
121 | CFStreamCreatePairWithSocketToHost(
122 | kCFAllocatorDefault,
123 | host as CFString,
| `- error: cannot find type 'CFString' in scope
124 | UInt32(port),
125 | &readStream,
/host/spi-builder-workspace/Sources/Franz/Connection.swift:132:3: error: cannot find 'DispatchQueue' in scope
130 | outputStream = writeStream?.takeUnretainedValue()
131 |
132 | DispatchQueue(label: "FranzConnection").async {
| `- error: cannot find 'DispatchQueue' in scope
133 | self.inputStream?.delegate = self
134 | self.inputStream?.schedule(
/host/spi-builder-workspace/Sources/Franz/Connection.swift:136:14: error: cannot find 'RunLoopMode' in scope
134 | self.inputStream?.schedule(
135 | in: RunLoop.current,
136 | forMode: RunLoopMode.defaultRunLoopMode
| `- error: cannot find 'RunLoopMode' in scope
137 | )
138 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:142:14: error: cannot find 'RunLoopMode' in scope
140 | self.outputStream?.schedule(
141 | in: RunLoop.current,
142 | forMode: RunLoopMode.defaultRunLoopMode
| `- error: cannot find 'RunLoopMode' in scope
143 | )
144 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:221:3: error: cannot find 'DispatchQueue' in scope
219 | func makeCorrelationId() -> Int32 {
220 | var id: Int32!
221 | DispatchQueue(label: "FranzMakeCorrelationId").sync {
| `- error: cannot find 'DispatchQueue' in scope
222 | id = Connection.correlationId
223 | Connection.correlationId += 1
/host/spi-builder-workspace/Sources/Franz/Connection.swift:242:23: error: cannot find 'DispatchWorkItem' in scope
240 | }
241 | }
242 | let dispatchBlock = DispatchWorkItem(qos: .unspecified, flags: []) {
| `- error: cannot find 'DispatchWorkItem' in scope
243 | guard let stream = self.outputStream else {
244 | return
/host/spi-builder-workspace/Sources/Franz/Connection.swift:242:46: error: cannot infer contextual base in reference to member 'unspecified'
240 | }
241 | }
242 | let dispatchBlock = DispatchWorkItem(qos: .unspecified, flags: []) {
| `- error: cannot infer contextual base in reference to member 'unspecified'
243 | guard let stream = self.outputStream else {
244 | return
/host/spi-builder-workspace/Sources/Franz/Connection.swift:268:19: error: cannot find 'DispatchSemaphore' in scope
266 |
267 | func writeBlocking<T: KafkaRequest>(_ request: T) -> T.Response? {
268 | let semaphore = DispatchSemaphore(value: 0)
| `- error: cannot find 'DispatchSemaphore' in scope
269 | var response: T.Response?
270 | write(request, callback: { r in
/host/spi-builder-workspace/Sources/Franz/Connection.swift:288:22: warning: result of call to 'read(_:maxLength:)' is unused [#no-usage]
286 | var buffer = Array<UInt8>(repeating: 0, count: Int(length))
287 | if activeInputStream.hasBytesAvailable {
288 | activeInputStream.read(&buffer, maxLength: Int(length))
| `- warning: result of call to 'read(_:maxLength:)' is unused [#no-usage]
289 | } else {
290 | throw ConnectionError.bytesNoLongerAvailable
/host/spi-builder-workspace/Sources/Franz/Connection.swift:375:49: error: type 'RunLoop.Mode' has no member 'defaultRunLoopMode'
373 | outputStream?.close()
374 | if let runLoop = runLoop {
375 | inputStream?.remove(from: runLoop, forMode: .defaultRunLoopMode)
| `- error: type 'RunLoop.Mode' has no member 'defaultRunLoopMode'
376 | outputStream?.remove(from: runLoop, forMode: .defaultRunLoopMode)
377 | }
/host/spi-builder-workspace/Sources/Franz/Connection.swift:376:50: error: type 'RunLoop.Mode' has no member 'defaultRunLoopMode'
374 | if let runLoop = runLoop {
375 | inputStream?.remove(from: runLoop, forMode: .defaultRunLoopMode)
376 | outputStream?.remove(from: runLoop, forMode: .defaultRunLoopMode)
| `- error: type 'RunLoop.Mode' has no member 'defaultRunLoopMode'
377 | }
378 | requestCallbacks.forEach { $1(nil) }
[23/32] Compiling Franz Broker.swift
/host/spi-builder-workspace/Sources/Franz/Broker.swift:491:39: error: cannot find type 'DispatchQueue' in scope
489 | private var _readQueues = [Int32: DispatchQueue]()
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
492 | return DispatchQueue(
493 | label: "metadata.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:498:40: error: cannot find type 'DispatchQueue' in scope
496 | }()
497 |
498 | private lazy var _metadataWriteQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
499 | return DispatchQueue(
500 | label: "metadata.write.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:505:36: error: cannot find type 'DispatchQueue' in scope
503 | }()
504 |
505 | private lazy var _adminReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
506 | return DispatchQueue(
507 | label: "admin.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:512:44: error: cannot find type 'DispatchQueue' in scope
510 | }()
511 |
512 | private lazy var _groupCoordinationQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
513 | return DispatchQueue(
514 | label: "group.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:472:69: error: cannot find type 'DispatchQueue' in scope
470 | }
471 |
472 | private func getReadQueue(_ topic: String, partition: Int32) -> DispatchQueue {
| `- error: cannot find type 'DispatchQueue' in scope
473 | var readQueue: DispatchQueue
474 | if let pq = _readQueues[partition] {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:489:36: error: cannot find 'DispatchQueue' in scope
487 | //MARK: Queues
488 |
489 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot find 'DispatchQueue' in scope
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:489:28: error: cannot call value of non-function type '[AnyHashable : Any]'
487 | //MARK: Queues
488 |
489 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot call value of non-function type '[AnyHashable : Any]'
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:489:29: error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
487 | //MARK: Queues
488 |
489 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:492:10: error: cannot find 'DispatchQueue' in scope
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
492 | return DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
493 | label: "metadata.read.stream.franz",
494 | attributes: []
/host/spi-builder-workspace/Sources/Franz/Broker.swift:499:10: error: cannot find 'DispatchQueue' in scope
497 |
498 | private lazy var _metadataWriteQueue: DispatchQueue = {
499 | return DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
500 | label: "metadata.write.stream.franz",
501 | attributes: []
/host/spi-builder-workspace/Sources/Franz/Broker.swift:506:10: error: cannot find 'DispatchQueue' in scope
504 |
505 | private lazy var _adminReadQueue: DispatchQueue = {
506 | return DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
507 | label: "admin.read.stream.franz",
508 | attributes: []
/host/spi-builder-workspace/Sources/Franz/Broker.swift:513:10: error: cannot find 'DispatchQueue' in scope
511 |
512 | private lazy var _groupCoordinationQueue: DispatchQueue = {
513 | return DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
514 | label: "group.read.stream.franz",
515 | attributes: []
/host/spi-builder-workspace/Sources/Franz/Broker.swift:189:54: error: cannot call value of non-function type 'Date'
187 | case .rebalanceInProgressCode:
188 | print("Rebalance in progress, retrying offset commit after 1 second")
189 | self._metadataReadQueue.asyncAfter(deadline: .now() + 1) {
| `- error: cannot call value of non-function type 'Date'
190 | self.commitGroupOffset(groupId: groupId, topics: topics)
191 | }
/host/spi-builder-workspace/Sources/Franz/Broker.swift:473:24: error: cannot find type 'DispatchQueue' in scope
471 |
472 | private func getReadQueue(_ topic: String, partition: Int32) -> DispatchQueue {
473 | var readQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
474 | if let pq = _readQueues[partition] {
475 | readQueue = pq
/host/spi-builder-workspace/Sources/Franz/Broker.swift:477:38: error: cannot find 'DispatchQueue' in scope
475 | readQueue = pq
476 | } else {
477 | _readQueues[partition] = DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
478 | label: "\(partition).\(topic).read.stream.franz",
479 | attributes: DispatchQueue.Attributes.concurrent
/host/spi-builder-workspace/Sources/Franz/Broker.swift:479:29: error: cannot find 'DispatchQueue' in scope
477 | _readQueues[partition] = DispatchQueue(
478 | label: "\(partition).\(topic).read.stream.franz",
479 | attributes: DispatchQueue.Attributes.concurrent
| `- error: cannot find 'DispatchQueue' in scope
480 | )
481 | readQueue = _readQueues[partition]!
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:35:29: error: cannot find type 'DispatchQueue' in scope
33 | let nodeId: ReplicaId
34 |
35 | lazy var dispatchQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
36 | return DispatchQueue(label: "metadata.cluster.read.stream.franz")
37 | }()
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:36:16: error: cannot find 'DispatchQueue' in scope
34 |
35 | lazy var dispatchQueue: DispatchQueue = {
36 | return DispatchQueue(label: "metadata.cluster.read.stream.franz")
| `- error: cannot find 'DispatchQueue' in scope
37 | }()
38 |
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:404:33: error: cannot find 'DispatchWorkItem' in scope
402 |
403 | for (_, broker) in brokers {
404 | let dispatchBlock = DispatchWorkItem(qos: .unspecified, flags: []) {
| `- error: cannot find 'DispatchWorkItem' in scope
405 |
406 | var handleGetTopicMetadata: ((MetadataResponse) -> Void)!
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:414:29: error: cannot find 'Thread' in scope
412 | let retryTopics = response.topics.filter { key, val in val.error == .leaderNotAvailable }.compactMap { $1.name }
413 | print("Leader not available, trying to find leader again in 1 second")
414 | Thread.sleep(forTimeInterval: 1)
| `- error: cannot find 'Thread' in scope
415 | broker.getTopicMetadata(topics: retryTopics, completion: handleGetTopicMetadata)
416 | return
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:404:56: error: cannot infer contextual base in reference to member 'unspecified'
402 |
403 | for (_, broker) in brokers {
404 | let dispatchBlock = DispatchWorkItem(qos: .unspecified, flags: []) {
| `- error: cannot infer contextual base in reference to member 'unspecified'
405 |
406 | var handleGetTopicMetadata: ((MetadataResponse) -> Void)!
/host/spi-builder-workspace/Sources/Franz/Connection.swift:89:39: error: cannot find type 'CFReadStream' in scope
87 | private var clientId: String
88 |
89 | private var readStream: Unmanaged<CFReadStream>?
| `- error: cannot find type 'CFReadStream' in scope
90 | private var writeStream: Unmanaged<CFWriteStream>?
91 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:90:40: error: cannot find type 'CFWriteStream' in scope
88 |
89 | private var readStream: Unmanaged<CFReadStream>?
90 | private var writeStream: Unmanaged<CFWriteStream>?
| `- error: cannot find type 'CFWriteStream' in scope
91 |
92 | private var inputStream: InputStream?
/host/spi-builder-workspace/Sources/Franz/Connection.swift:98:35: error: cannot find type 'DispatchQueue' in scope
96 | private let responseCorrelationIdSize: Int32 = 4
97 |
98 | private var inputStreamQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
99 | private var outputStreamQueue: DispatchQueue
100 | private var writeRequestBlocks = [()->()]()
/host/spi-builder-workspace/Sources/Franz/Connection.swift:99:36: error: cannot find type 'DispatchQueue' in scope
97 |
98 | private var inputStreamQueue: DispatchQueue
99 | private var outputStreamQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
100 | private var writeRequestBlocks = [()->()]()
101 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:116:28: error: cannot find 'DispatchQueue' in scope
114 | self.port = config.port
115 |
116 | inputStreamQueue = DispatchQueue(label: "\(self.host).\(self.port).input.stream.franz")
| `- error: cannot find 'DispatchQueue' in scope
117 | outputStreamQueue = DispatchQueue(label: "\(self.host).\(self.port).output.stream.franz")
118 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:117:23: error: cannot find 'DispatchQueue' in scope
115 |
116 | inputStreamQueue = DispatchQueue(label: "\(self.host).\(self.port).input.stream.franz")
117 | outputStreamQueue = DispatchQueue(label: "\(self.host).\(self.port).output.stream.franz")
| `- error: cannot find 'DispatchQueue' in scope
118 |
119 | super.init()
/host/spi-builder-workspace/Sources/Franz/Connection.swift:121:9: error: cannot find 'CFStreamCreatePairWithSocketToHost' in scope
119 | super.init()
120 |
121 | CFStreamCreatePairWithSocketToHost(
| `- error: cannot find 'CFStreamCreatePairWithSocketToHost' in scope
122 | kCFAllocatorDefault,
123 | host as CFString,
/host/spi-builder-workspace/Sources/Franz/Connection.swift:122:13: error: cannot find 'kCFAllocatorDefault' in scope
120 |
121 | CFStreamCreatePairWithSocketToHost(
122 | kCFAllocatorDefault,
| `- error: cannot find 'kCFAllocatorDefault' in scope
123 | host as CFString,
124 | UInt32(port),
/host/spi-builder-workspace/Sources/Franz/Connection.swift:123:21: error: cannot find type 'CFString' in scope
121 | CFStreamCreatePairWithSocketToHost(
122 | kCFAllocatorDefault,
123 | host as CFString,
| `- error: cannot find type 'CFString' in scope
124 | UInt32(port),
125 | &readStream,
/host/spi-builder-workspace/Sources/Franz/Connection.swift:132:3: error: cannot find 'DispatchQueue' in scope
130 | outputStream = writeStream?.takeUnretainedValue()
131 |
132 | DispatchQueue(label: "FranzConnection").async {
| `- error: cannot find 'DispatchQueue' in scope
133 | self.inputStream?.delegate = self
134 | self.inputStream?.schedule(
/host/spi-builder-workspace/Sources/Franz/Connection.swift:136:14: error: cannot find 'RunLoopMode' in scope
134 | self.inputStream?.schedule(
135 | in: RunLoop.current,
136 | forMode: RunLoopMode.defaultRunLoopMode
| `- error: cannot find 'RunLoopMode' in scope
137 | )
138 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:142:14: error: cannot find 'RunLoopMode' in scope
140 | self.outputStream?.schedule(
141 | in: RunLoop.current,
142 | forMode: RunLoopMode.defaultRunLoopMode
| `- error: cannot find 'RunLoopMode' in scope
143 | )
144 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:221:3: error: cannot find 'DispatchQueue' in scope
219 | func makeCorrelationId() -> Int32 {
220 | var id: Int32!
221 | DispatchQueue(label: "FranzMakeCorrelationId").sync {
| `- error: cannot find 'DispatchQueue' in scope
222 | id = Connection.correlationId
223 | Connection.correlationId += 1
/host/spi-builder-workspace/Sources/Franz/Connection.swift:242:23: error: cannot find 'DispatchWorkItem' in scope
240 | }
241 | }
242 | let dispatchBlock = DispatchWorkItem(qos: .unspecified, flags: []) {
| `- error: cannot find 'DispatchWorkItem' in scope
243 | guard let stream = self.outputStream else {
244 | return
/host/spi-builder-workspace/Sources/Franz/Connection.swift:242:46: error: cannot infer contextual base in reference to member 'unspecified'
240 | }
241 | }
242 | let dispatchBlock = DispatchWorkItem(qos: .unspecified, flags: []) {
| `- error: cannot infer contextual base in reference to member 'unspecified'
243 | guard let stream = self.outputStream else {
244 | return
/host/spi-builder-workspace/Sources/Franz/Connection.swift:268:19: error: cannot find 'DispatchSemaphore' in scope
266 |
267 | func writeBlocking<T: KafkaRequest>(_ request: T) -> T.Response? {
268 | let semaphore = DispatchSemaphore(value: 0)
| `- error: cannot find 'DispatchSemaphore' in scope
269 | var response: T.Response?
270 | write(request, callback: { r in
/host/spi-builder-workspace/Sources/Franz/Connection.swift:288:22: warning: result of call to 'read(_:maxLength:)' is unused [#no-usage]
286 | var buffer = Array<UInt8>(repeating: 0, count: Int(length))
287 | if activeInputStream.hasBytesAvailable {
288 | activeInputStream.read(&buffer, maxLength: Int(length))
| `- warning: result of call to 'read(_:maxLength:)' is unused [#no-usage]
289 | } else {
290 | throw ConnectionError.bytesNoLongerAvailable
/host/spi-builder-workspace/Sources/Franz/Connection.swift:375:49: error: type 'RunLoop.Mode' has no member 'defaultRunLoopMode'
373 | outputStream?.close()
374 | if let runLoop = runLoop {
375 | inputStream?.remove(from: runLoop, forMode: .defaultRunLoopMode)
| `- error: type 'RunLoop.Mode' has no member 'defaultRunLoopMode'
376 | outputStream?.remove(from: runLoop, forMode: .defaultRunLoopMode)
377 | }
/host/spi-builder-workspace/Sources/Franz/Connection.swift:376:50: error: type 'RunLoop.Mode' has no member 'defaultRunLoopMode'
374 | if let runLoop = runLoop {
375 | inputStream?.remove(from: runLoop, forMode: .defaultRunLoopMode)
376 | outputStream?.remove(from: runLoop, forMode: .defaultRunLoopMode)
| `- error: type 'RunLoop.Mode' has no member 'defaultRunLoopMode'
377 | }
378 | requestCallbacks.forEach { $1(nil) }
[24/32] Compiling Franz Cluster.swift
/host/spi-builder-workspace/Sources/Franz/Broker.swift:491:39: error: cannot find type 'DispatchQueue' in scope
489 | private var _readQueues = [Int32: DispatchQueue]()
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
492 | return DispatchQueue(
493 | label: "metadata.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:498:40: error: cannot find type 'DispatchQueue' in scope
496 | }()
497 |
498 | private lazy var _metadataWriteQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
499 | return DispatchQueue(
500 | label: "metadata.write.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:505:36: error: cannot find type 'DispatchQueue' in scope
503 | }()
504 |
505 | private lazy var _adminReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
506 | return DispatchQueue(
507 | label: "admin.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:512:44: error: cannot find type 'DispatchQueue' in scope
510 | }()
511 |
512 | private lazy var _groupCoordinationQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
513 | return DispatchQueue(
514 | label: "group.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:472:69: error: cannot find type 'DispatchQueue' in scope
470 | }
471 |
472 | private func getReadQueue(_ topic: String, partition: Int32) -> DispatchQueue {
| `- error: cannot find type 'DispatchQueue' in scope
473 | var readQueue: DispatchQueue
474 | if let pq = _readQueues[partition] {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:489:36: error: cannot find 'DispatchQueue' in scope
487 | //MARK: Queues
488 |
489 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot find 'DispatchQueue' in scope
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:489:28: error: cannot call value of non-function type '[AnyHashable : Any]'
487 | //MARK: Queues
488 |
489 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot call value of non-function type '[AnyHashable : Any]'
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:489:29: error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
487 | //MARK: Queues
488 |
489 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:492:10: error: cannot find 'DispatchQueue' in scope
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
492 | return DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
493 | label: "metadata.read.stream.franz",
494 | attributes: []
/host/spi-builder-workspace/Sources/Franz/Broker.swift:499:10: error: cannot find 'DispatchQueue' in scope
497 |
498 | private lazy var _metadataWriteQueue: DispatchQueue = {
499 | return DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
500 | label: "metadata.write.stream.franz",
501 | attributes: []
/host/spi-builder-workspace/Sources/Franz/Broker.swift:506:10: error: cannot find 'DispatchQueue' in scope
504 |
505 | private lazy var _adminReadQueue: DispatchQueue = {
506 | return DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
507 | label: "admin.read.stream.franz",
508 | attributes: []
/host/spi-builder-workspace/Sources/Franz/Broker.swift:513:10: error: cannot find 'DispatchQueue' in scope
511 |
512 | private lazy var _groupCoordinationQueue: DispatchQueue = {
513 | return DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
514 | label: "group.read.stream.franz",
515 | attributes: []
/host/spi-builder-workspace/Sources/Franz/Broker.swift:189:54: error: cannot call value of non-function type 'Date'
187 | case .rebalanceInProgressCode:
188 | print("Rebalance in progress, retrying offset commit after 1 second")
189 | self._metadataReadQueue.asyncAfter(deadline: .now() + 1) {
| `- error: cannot call value of non-function type 'Date'
190 | self.commitGroupOffset(groupId: groupId, topics: topics)
191 | }
/host/spi-builder-workspace/Sources/Franz/Broker.swift:473:24: error: cannot find type 'DispatchQueue' in scope
471 |
472 | private func getReadQueue(_ topic: String, partition: Int32) -> DispatchQueue {
473 | var readQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
474 | if let pq = _readQueues[partition] {
475 | readQueue = pq
/host/spi-builder-workspace/Sources/Franz/Broker.swift:477:38: error: cannot find 'DispatchQueue' in scope
475 | readQueue = pq
476 | } else {
477 | _readQueues[partition] = DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
478 | label: "\(partition).\(topic).read.stream.franz",
479 | attributes: DispatchQueue.Attributes.concurrent
/host/spi-builder-workspace/Sources/Franz/Broker.swift:479:29: error: cannot find 'DispatchQueue' in scope
477 | _readQueues[partition] = DispatchQueue(
478 | label: "\(partition).\(topic).read.stream.franz",
479 | attributes: DispatchQueue.Attributes.concurrent
| `- error: cannot find 'DispatchQueue' in scope
480 | )
481 | readQueue = _readQueues[partition]!
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:35:29: error: cannot find type 'DispatchQueue' in scope
33 | let nodeId: ReplicaId
34 |
35 | lazy var dispatchQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
36 | return DispatchQueue(label: "metadata.cluster.read.stream.franz")
37 | }()
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:36:16: error: cannot find 'DispatchQueue' in scope
34 |
35 | lazy var dispatchQueue: DispatchQueue = {
36 | return DispatchQueue(label: "metadata.cluster.read.stream.franz")
| `- error: cannot find 'DispatchQueue' in scope
37 | }()
38 |
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:404:33: error: cannot find 'DispatchWorkItem' in scope
402 |
403 | for (_, broker) in brokers {
404 | let dispatchBlock = DispatchWorkItem(qos: .unspecified, flags: []) {
| `- error: cannot find 'DispatchWorkItem' in scope
405 |
406 | var handleGetTopicMetadata: ((MetadataResponse) -> Void)!
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:414:29: error: cannot find 'Thread' in scope
412 | let retryTopics = response.topics.filter { key, val in val.error == .leaderNotAvailable }.compactMap { $1.name }
413 | print("Leader not available, trying to find leader again in 1 second")
414 | Thread.sleep(forTimeInterval: 1)
| `- error: cannot find 'Thread' in scope
415 | broker.getTopicMetadata(topics: retryTopics, completion: handleGetTopicMetadata)
416 | return
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:404:56: error: cannot infer contextual base in reference to member 'unspecified'
402 |
403 | for (_, broker) in brokers {
404 | let dispatchBlock = DispatchWorkItem(qos: .unspecified, flags: []) {
| `- error: cannot infer contextual base in reference to member 'unspecified'
405 |
406 | var handleGetTopicMetadata: ((MetadataResponse) -> Void)!
/host/spi-builder-workspace/Sources/Franz/Connection.swift:89:39: error: cannot find type 'CFReadStream' in scope
87 | private var clientId: String
88 |
89 | private var readStream: Unmanaged<CFReadStream>?
| `- error: cannot find type 'CFReadStream' in scope
90 | private var writeStream: Unmanaged<CFWriteStream>?
91 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:90:40: error: cannot find type 'CFWriteStream' in scope
88 |
89 | private var readStream: Unmanaged<CFReadStream>?
90 | private var writeStream: Unmanaged<CFWriteStream>?
| `- error: cannot find type 'CFWriteStream' in scope
91 |
92 | private var inputStream: InputStream?
/host/spi-builder-workspace/Sources/Franz/Connection.swift:98:35: error: cannot find type 'DispatchQueue' in scope
96 | private let responseCorrelationIdSize: Int32 = 4
97 |
98 | private var inputStreamQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
99 | private var outputStreamQueue: DispatchQueue
100 | private var writeRequestBlocks = [()->()]()
/host/spi-builder-workspace/Sources/Franz/Connection.swift:99:36: error: cannot find type 'DispatchQueue' in scope
97 |
98 | private var inputStreamQueue: DispatchQueue
99 | private var outputStreamQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
100 | private var writeRequestBlocks = [()->()]()
101 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:116:28: error: cannot find 'DispatchQueue' in scope
114 | self.port = config.port
115 |
116 | inputStreamQueue = DispatchQueue(label: "\(self.host).\(self.port).input.stream.franz")
| `- error: cannot find 'DispatchQueue' in scope
117 | outputStreamQueue = DispatchQueue(label: "\(self.host).\(self.port).output.stream.franz")
118 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:117:23: error: cannot find 'DispatchQueue' in scope
115 |
116 | inputStreamQueue = DispatchQueue(label: "\(self.host).\(self.port).input.stream.franz")
117 | outputStreamQueue = DispatchQueue(label: "\(self.host).\(self.port).output.stream.franz")
| `- error: cannot find 'DispatchQueue' in scope
118 |
119 | super.init()
/host/spi-builder-workspace/Sources/Franz/Connection.swift:121:9: error: cannot find 'CFStreamCreatePairWithSocketToHost' in scope
119 | super.init()
120 |
121 | CFStreamCreatePairWithSocketToHost(
| `- error: cannot find 'CFStreamCreatePairWithSocketToHost' in scope
122 | kCFAllocatorDefault,
123 | host as CFString,
/host/spi-builder-workspace/Sources/Franz/Connection.swift:122:13: error: cannot find 'kCFAllocatorDefault' in scope
120 |
121 | CFStreamCreatePairWithSocketToHost(
122 | kCFAllocatorDefault,
| `- error: cannot find 'kCFAllocatorDefault' in scope
123 | host as CFString,
124 | UInt32(port),
/host/spi-builder-workspace/Sources/Franz/Connection.swift:123:21: error: cannot find type 'CFString' in scope
121 | CFStreamCreatePairWithSocketToHost(
122 | kCFAllocatorDefault,
123 | host as CFString,
| `- error: cannot find type 'CFString' in scope
124 | UInt32(port),
125 | &readStream,
/host/spi-builder-workspace/Sources/Franz/Connection.swift:132:3: error: cannot find 'DispatchQueue' in scope
130 | outputStream = writeStream?.takeUnretainedValue()
131 |
132 | DispatchQueue(label: "FranzConnection").async {
| `- error: cannot find 'DispatchQueue' in scope
133 | self.inputStream?.delegate = self
134 | self.inputStream?.schedule(
/host/spi-builder-workspace/Sources/Franz/Connection.swift:136:14: error: cannot find 'RunLoopMode' in scope
134 | self.inputStream?.schedule(
135 | in: RunLoop.current,
136 | forMode: RunLoopMode.defaultRunLoopMode
| `- error: cannot find 'RunLoopMode' in scope
137 | )
138 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:142:14: error: cannot find 'RunLoopMode' in scope
140 | self.outputStream?.schedule(
141 | in: RunLoop.current,
142 | forMode: RunLoopMode.defaultRunLoopMode
| `- error: cannot find 'RunLoopMode' in scope
143 | )
144 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:221:3: error: cannot find 'DispatchQueue' in scope
219 | func makeCorrelationId() -> Int32 {
220 | var id: Int32!
221 | DispatchQueue(label: "FranzMakeCorrelationId").sync {
| `- error: cannot find 'DispatchQueue' in scope
222 | id = Connection.correlationId
223 | Connection.correlationId += 1
/host/spi-builder-workspace/Sources/Franz/Connection.swift:242:23: error: cannot find 'DispatchWorkItem' in scope
240 | }
241 | }
242 | let dispatchBlock = DispatchWorkItem(qos: .unspecified, flags: []) {
| `- error: cannot find 'DispatchWorkItem' in scope
243 | guard let stream = self.outputStream else {
244 | return
/host/spi-builder-workspace/Sources/Franz/Connection.swift:242:46: error: cannot infer contextual base in reference to member 'unspecified'
240 | }
241 | }
242 | let dispatchBlock = DispatchWorkItem(qos: .unspecified, flags: []) {
| `- error: cannot infer contextual base in reference to member 'unspecified'
243 | guard let stream = self.outputStream else {
244 | return
/host/spi-builder-workspace/Sources/Franz/Connection.swift:268:19: error: cannot find 'DispatchSemaphore' in scope
266 |
267 | func writeBlocking<T: KafkaRequest>(_ request: T) -> T.Response? {
268 | let semaphore = DispatchSemaphore(value: 0)
| `- error: cannot find 'DispatchSemaphore' in scope
269 | var response: T.Response?
270 | write(request, callback: { r in
/host/spi-builder-workspace/Sources/Franz/Connection.swift:288:22: warning: result of call to 'read(_:maxLength:)' is unused [#no-usage]
286 | var buffer = Array<UInt8>(repeating: 0, count: Int(length))
287 | if activeInputStream.hasBytesAvailable {
288 | activeInputStream.read(&buffer, maxLength: Int(length))
| `- warning: result of call to 'read(_:maxLength:)' is unused [#no-usage]
289 | } else {
290 | throw ConnectionError.bytesNoLongerAvailable
/host/spi-builder-workspace/Sources/Franz/Connection.swift:375:49: error: type 'RunLoop.Mode' has no member 'defaultRunLoopMode'
373 | outputStream?.close()
374 | if let runLoop = runLoop {
375 | inputStream?.remove(from: runLoop, forMode: .defaultRunLoopMode)
| `- error: type 'RunLoop.Mode' has no member 'defaultRunLoopMode'
376 | outputStream?.remove(from: runLoop, forMode: .defaultRunLoopMode)
377 | }
/host/spi-builder-workspace/Sources/Franz/Connection.swift:376:50: error: type 'RunLoop.Mode' has no member 'defaultRunLoopMode'
374 | if let runLoop = runLoop {
375 | inputStream?.remove(from: runLoop, forMode: .defaultRunLoopMode)
376 | outputStream?.remove(from: runLoop, forMode: .defaultRunLoopMode)
| `- error: type 'RunLoop.Mode' has no member 'defaultRunLoopMode'
377 | }
378 | requestCallbacks.forEach { $1(nil) }
[25/32] Compiling Franz Connection.swift
/host/spi-builder-workspace/Sources/Franz/Broker.swift:491:39: error: cannot find type 'DispatchQueue' in scope
489 | private var _readQueues = [Int32: DispatchQueue]()
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
492 | return DispatchQueue(
493 | label: "metadata.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:498:40: error: cannot find type 'DispatchQueue' in scope
496 | }()
497 |
498 | private lazy var _metadataWriteQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
499 | return DispatchQueue(
500 | label: "metadata.write.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:505:36: error: cannot find type 'DispatchQueue' in scope
503 | }()
504 |
505 | private lazy var _adminReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
506 | return DispatchQueue(
507 | label: "admin.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:512:44: error: cannot find type 'DispatchQueue' in scope
510 | }()
511 |
512 | private lazy var _groupCoordinationQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
513 | return DispatchQueue(
514 | label: "group.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:472:69: error: cannot find type 'DispatchQueue' in scope
470 | }
471 |
472 | private func getReadQueue(_ topic: String, partition: Int32) -> DispatchQueue {
| `- error: cannot find type 'DispatchQueue' in scope
473 | var readQueue: DispatchQueue
474 | if let pq = _readQueues[partition] {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:489:36: error: cannot find 'DispatchQueue' in scope
487 | //MARK: Queues
488 |
489 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot find 'DispatchQueue' in scope
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:489:28: error: cannot call value of non-function type '[AnyHashable : Any]'
487 | //MARK: Queues
488 |
489 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot call value of non-function type '[AnyHashable : Any]'
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:489:29: error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
487 | //MARK: Queues
488 |
489 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:492:10: error: cannot find 'DispatchQueue' in scope
490 |
491 | private lazy var _metadataReadQueue: DispatchQueue = {
492 | return DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
493 | label: "metadata.read.stream.franz",
494 | attributes: []
/host/spi-builder-workspace/Sources/Franz/Broker.swift:499:10: error: cannot find 'DispatchQueue' in scope
497 |
498 | private lazy var _metadataWriteQueue: DispatchQueue = {
499 | return DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
500 | label: "metadata.write.stream.franz",
501 | attributes: []
/host/spi-builder-workspace/Sources/Franz/Broker.swift:506:10: error: cannot find 'DispatchQueue' in scope
504 |
505 | private lazy var _adminReadQueue: DispatchQueue = {
506 | return DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
507 | label: "admin.read.stream.franz",
508 | attributes: []
/host/spi-builder-workspace/Sources/Franz/Broker.swift:513:10: error: cannot find 'DispatchQueue' in scope
511 |
512 | private lazy var _groupCoordinationQueue: DispatchQueue = {
513 | return DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
514 | label: "group.read.stream.franz",
515 | attributes: []
/host/spi-builder-workspace/Sources/Franz/Broker.swift:189:54: error: cannot call value of non-function type 'Date'
187 | case .rebalanceInProgressCode:
188 | print("Rebalance in progress, retrying offset commit after 1 second")
189 | self._metadataReadQueue.asyncAfter(deadline: .now() + 1) {
| `- error: cannot call value of non-function type 'Date'
190 | self.commitGroupOffset(groupId: groupId, topics: topics)
191 | }
/host/spi-builder-workspace/Sources/Franz/Broker.swift:473:24: error: cannot find type 'DispatchQueue' in scope
471 |
472 | private func getReadQueue(_ topic: String, partition: Int32) -> DispatchQueue {
473 | var readQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
474 | if let pq = _readQueues[partition] {
475 | readQueue = pq
/host/spi-builder-workspace/Sources/Franz/Broker.swift:477:38: error: cannot find 'DispatchQueue' in scope
475 | readQueue = pq
476 | } else {
477 | _readQueues[partition] = DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
478 | label: "\(partition).\(topic).read.stream.franz",
479 | attributes: DispatchQueue.Attributes.concurrent
/host/spi-builder-workspace/Sources/Franz/Broker.swift:479:29: error: cannot find 'DispatchQueue' in scope
477 | _readQueues[partition] = DispatchQueue(
478 | label: "\(partition).\(topic).read.stream.franz",
479 | attributes: DispatchQueue.Attributes.concurrent
| `- error: cannot find 'DispatchQueue' in scope
480 | )
481 | readQueue = _readQueues[partition]!
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:35:29: error: cannot find type 'DispatchQueue' in scope
33 | let nodeId: ReplicaId
34 |
35 | lazy var dispatchQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
36 | return DispatchQueue(label: "metadata.cluster.read.stream.franz")
37 | }()
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:36:16: error: cannot find 'DispatchQueue' in scope
34 |
35 | lazy var dispatchQueue: DispatchQueue = {
36 | return DispatchQueue(label: "metadata.cluster.read.stream.franz")
| `- error: cannot find 'DispatchQueue' in scope
37 | }()
38 |
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:404:33: error: cannot find 'DispatchWorkItem' in scope
402 |
403 | for (_, broker) in brokers {
404 | let dispatchBlock = DispatchWorkItem(qos: .unspecified, flags: []) {
| `- error: cannot find 'DispatchWorkItem' in scope
405 |
406 | var handleGetTopicMetadata: ((MetadataResponse) -> Void)!
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:414:29: error: cannot find 'Thread' in scope
412 | let retryTopics = response.topics.filter { key, val in val.error == .leaderNotAvailable }.compactMap { $1.name }
413 | print("Leader not available, trying to find leader again in 1 second")
414 | Thread.sleep(forTimeInterval: 1)
| `- error: cannot find 'Thread' in scope
415 | broker.getTopicMetadata(topics: retryTopics, completion: handleGetTopicMetadata)
416 | return
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:404:56: error: cannot infer contextual base in reference to member 'unspecified'
402 |
403 | for (_, broker) in brokers {
404 | let dispatchBlock = DispatchWorkItem(qos: .unspecified, flags: []) {
| `- error: cannot infer contextual base in reference to member 'unspecified'
405 |
406 | var handleGetTopicMetadata: ((MetadataResponse) -> Void)!
/host/spi-builder-workspace/Sources/Franz/Connection.swift:89:39: error: cannot find type 'CFReadStream' in scope
87 | private var clientId: String
88 |
89 | private var readStream: Unmanaged<CFReadStream>?
| `- error: cannot find type 'CFReadStream' in scope
90 | private var writeStream: Unmanaged<CFWriteStream>?
91 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:90:40: error: cannot find type 'CFWriteStream' in scope
88 |
89 | private var readStream: Unmanaged<CFReadStream>?
90 | private var writeStream: Unmanaged<CFWriteStream>?
| `- error: cannot find type 'CFWriteStream' in scope
91 |
92 | private var inputStream: InputStream?
/host/spi-builder-workspace/Sources/Franz/Connection.swift:98:35: error: cannot find type 'DispatchQueue' in scope
96 | private let responseCorrelationIdSize: Int32 = 4
97 |
98 | private var inputStreamQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
99 | private var outputStreamQueue: DispatchQueue
100 | private var writeRequestBlocks = [()->()]()
/host/spi-builder-workspace/Sources/Franz/Connection.swift:99:36: error: cannot find type 'DispatchQueue' in scope
97 |
98 | private var inputStreamQueue: DispatchQueue
99 | private var outputStreamQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
100 | private var writeRequestBlocks = [()->()]()
101 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:116:28: error: cannot find 'DispatchQueue' in scope
114 | self.port = config.port
115 |
116 | inputStreamQueue = DispatchQueue(label: "\(self.host).\(self.port).input.stream.franz")
| `- error: cannot find 'DispatchQueue' in scope
117 | outputStreamQueue = DispatchQueue(label: "\(self.host).\(self.port).output.stream.franz")
118 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:117:23: error: cannot find 'DispatchQueue' in scope
115 |
116 | inputStreamQueue = DispatchQueue(label: "\(self.host).\(self.port).input.stream.franz")
117 | outputStreamQueue = DispatchQueue(label: "\(self.host).\(self.port).output.stream.franz")
| `- error: cannot find 'DispatchQueue' in scope
118 |
119 | super.init()
/host/spi-builder-workspace/Sources/Franz/Connection.swift:121:9: error: cannot find 'CFStreamCreatePairWithSocketToHost' in scope
119 | super.init()
120 |
121 | CFStreamCreatePairWithSocketToHost(
| `- error: cannot find 'CFStreamCreatePairWithSocketToHost' in scope
122 | kCFAllocatorDefault,
123 | host as CFString,
/host/spi-builder-workspace/Sources/Franz/Connection.swift:122:13: error: cannot find 'kCFAllocatorDefault' in scope
120 |
121 | CFStreamCreatePairWithSocketToHost(
122 | kCFAllocatorDefault,
| `- error: cannot find 'kCFAllocatorDefault' in scope
123 | host as CFString,
124 | UInt32(port),
/host/spi-builder-workspace/Sources/Franz/Connection.swift:123:21: error: cannot find type 'CFString' in scope
121 | CFStreamCreatePairWithSocketToHost(
122 | kCFAllocatorDefault,
123 | host as CFString,
| `- error: cannot find type 'CFString' in scope
124 | UInt32(port),
125 | &readStream,
/host/spi-builder-workspace/Sources/Franz/Connection.swift:132:3: error: cannot find 'DispatchQueue' in scope
130 | outputStream = writeStream?.takeUnretainedValue()
131 |
132 | DispatchQueue(label: "FranzConnection").async {
| `- error: cannot find 'DispatchQueue' in scope
133 | self.inputStream?.delegate = self
134 | self.inputStream?.schedule(
/host/spi-builder-workspace/Sources/Franz/Connection.swift:136:14: error: cannot find 'RunLoopMode' in scope
134 | self.inputStream?.schedule(
135 | in: RunLoop.current,
136 | forMode: RunLoopMode.defaultRunLoopMode
| `- error: cannot find 'RunLoopMode' in scope
137 | )
138 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:142:14: error: cannot find 'RunLoopMode' in scope
140 | self.outputStream?.schedule(
141 | in: RunLoop.current,
142 | forMode: RunLoopMode.defaultRunLoopMode
| `- error: cannot find 'RunLoopMode' in scope
143 | )
144 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:221:3: error: cannot find 'DispatchQueue' in scope
219 | func makeCorrelationId() -> Int32 {
220 | var id: Int32!
221 | DispatchQueue(label: "FranzMakeCorrelationId").sync {
| `- error: cannot find 'DispatchQueue' in scope
222 | id = Connection.correlationId
223 | Connection.correlationId += 1
/host/spi-builder-workspace/Sources/Franz/Connection.swift:242:23: error: cannot find 'DispatchWorkItem' in scope
240 | }
241 | }
242 | let dispatchBlock = DispatchWorkItem(qos: .unspecified, flags: []) {
| `- error: cannot find 'DispatchWorkItem' in scope
243 | guard let stream = self.outputStream else {
244 | return
/host/spi-builder-workspace/Sources/Franz/Connection.swift:242:46: error: cannot infer contextual base in reference to member 'unspecified'
240 | }
241 | }
242 | let dispatchBlock = DispatchWorkItem(qos: .unspecified, flags: []) {
| `- error: cannot infer contextual base in reference to member 'unspecified'
243 | guard let stream = self.outputStream else {
244 | return
/host/spi-builder-workspace/Sources/Franz/Connection.swift:268:19: error: cannot find 'DispatchSemaphore' in scope
266 |
267 | func writeBlocking<T: KafkaRequest>(_ request: T) -> T.Response? {
268 | let semaphore = DispatchSemaphore(value: 0)
| `- error: cannot find 'DispatchSemaphore' in scope
269 | var response: T.Response?
270 | write(request, callback: { r in
/host/spi-builder-workspace/Sources/Franz/Connection.swift:288:22: warning: result of call to 'read(_:maxLength:)' is unused [#no-usage]
286 | var buffer = Array<UInt8>(repeating: 0, count: Int(length))
287 | if activeInputStream.hasBytesAvailable {
288 | activeInputStream.read(&buffer, maxLength: Int(length))
| `- warning: result of call to 'read(_:maxLength:)' is unused [#no-usage]
289 | } else {
290 | throw ConnectionError.bytesNoLongerAvailable
/host/spi-builder-workspace/Sources/Franz/Connection.swift:375:49: error: type 'RunLoop.Mode' has no member 'defaultRunLoopMode'
373 | outputStream?.close()
374 | if let runLoop = runLoop {
375 | inputStream?.remove(from: runLoop, forMode: .defaultRunLoopMode)
| `- error: type 'RunLoop.Mode' has no member 'defaultRunLoopMode'
376 | outputStream?.remove(from: runLoop, forMode: .defaultRunLoopMode)
377 | }
/host/spi-builder-workspace/Sources/Franz/Connection.swift:376:50: error: type 'RunLoop.Mode' has no member 'defaultRunLoopMode'
374 | if let runLoop = runLoop {
375 | inputStream?.remove(from: runLoop, forMode: .defaultRunLoopMode)
376 | outputStream?.remove(from: runLoop, forMode: .defaultRunLoopMode)
| `- error: type 'RunLoop.Mode' has no member 'defaultRunLoopMode'
377 | }
378 | requestCallbacks.forEach { $1(nil) }
[26/32] Compiling Franz OffsetCommitAPI.swift
[27/32] Compiling Franz OffsetFetchAPI.swift
[28/32] Compiling Franz ProduceAPI.swift
[29/32] Compiling Franz SaslApi.swift
[30/32] Compiling Franz KafkaProtocol.swift
[31/32] Compiling Franz KafkaRequest.swift
[32/32] Compiling Franz KafkaResponse.swift
BUILD FAILURE 6.3 wasm