Swift Package IndexBuild Information
Failed to build Franz, reference 1.0.2 (c859f1), with Swift 6.1 for Wasm on 27 May 2025 07:26:22 UTC.
Build Command
bash -c docker run --pull=always --rm -v "checkouts-4609320-0":/host -w "$PWD" registry.gitlab.com/finestructure/spi-images:wasm-6.1-latest swift build --swift-sdk wasm32-unknown-wasi 2>&1Build Log
| `- error: cannot find 'DispatchQueue' in scope
40 |
41 | var offsetsToCommit = [TopicName: [PartitionId: (Offset, OffsetMetadata?)]]()
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:39:90: error: cannot infer contextual base in reference to member 'concurrent'
37 | }
38 |
39 | private let listenQueue = DispatchQueue(label: "FranzConsumerListenQueue", attributes: .concurrent)
| `- error: cannot infer contextual base in reference to member 'concurrent'
40 |
41 | var offsetsToCommit = [TopicName: [PartitionId: (Offset, OffsetMetadata?)]]()
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:42:3: error: Objective-C interoperability is disabled
40 |
41 | var offsetsToCommit = [TopicName: [PartitionId: (Offset, OffsetMetadata?)]]()
42 | @objc private func commitGroupoffsets() {
| `- error: Objective-C interoperability is disabled
43 | guard let groupId = self.membership?.group.id, let broker = self.broker else { return }
44 | broker.commitGroupOffset(groupId: groupId, topics: offsetsToCommit, clientId: cluster.clientId)
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:47:3: error: Objective-C interoperability is disabled
45 | }
46 |
47 | @objc private func sendHeartbeat() {
| `- error: Objective-C interoperability is disabled
48 | guard let groupId = self.membership?.group.id,
49 | let generationId = self.membership?.group.generationId,
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:28:10: warning: result of call to 'scheduledTimer(withTimeInterval:repeats:block:)' is unused
26 |
27 | if #available(OSX 10.12, iOS 10, tvOS 10, watchOS 3, *) {
28 | Timer.scheduledTimer(withTimeInterval: 5, repeats: true) { _ in self.commitGroupoffsets() }
| `- warning: result of call to 'scheduledTimer(withTimeInterval:repeats:block:)' is unused
29 | Timer.scheduledTimer(withTimeInterval: 3, repeats: true) { _ in
30 | self.sendHeartbeat()
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:29:10: warning: result of call to 'scheduledTimer(withTimeInterval:repeats:block:)' is unused
27 | if #available(OSX 10.12, iOS 10, tvOS 10, watchOS 3, *) {
28 | Timer.scheduledTimer(withTimeInterval: 5, repeats: true) { _ in self.commitGroupoffsets() }
29 | Timer.scheduledTimer(withTimeInterval: 3, repeats: true) { _ in
| `- warning: result of call to 'scheduledTimer(withTimeInterval:repeats:block:)' is unused
30 | self.sendHeartbeat()
31 | }
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:34:66: error: '#selector' can only be used with the Objective-C runtime
32 | } else {
33 | // Fallback on earlier versions
34 | Timer.scheduledTimer(timeInterval: 5, target: self, selector: #selector(commitGroupoffsets), userInfo: nil, repeats: true)
| `- error: '#selector' can only be used with the Objective-C runtime
35 | Timer.scheduledTimer(timeInterval: 3, target: self, selector: #selector(sendHeartbeat), userInfo: nil, repeats: true)
36 | }
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:35:66: error: '#selector' can only be used with the Objective-C runtime
33 | // Fallback on earlier versions
34 | Timer.scheduledTimer(timeInterval: 5, target: self, selector: #selector(commitGroupoffsets), userInfo: nil, repeats: true)
35 | Timer.scheduledTimer(timeInterval: 3, target: self, selector: #selector(sendHeartbeat), userInfo: nil, repeats: true)
| `- error: '#selector' can only be used with the Objective-C runtime
36 | }
37 | }
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:28:68: warning: capture of 'self' with non-sendable type 'Consumer' in a '@Sendable' closure; this is an error in the Swift 6 language mode
16 | - SeeAlso: `Cluster.getConsumer(topics: groupId:)`
17 | */
18 | public class Consumer {
| `- note: class 'Consumer' does not conform to the 'Sendable' protocol
19 | private let cluster: Cluster
20 | internal var broker: Broker?
:
26 |
27 | if #available(OSX 10.12, iOS 10, tvOS 10, watchOS 3, *) {
28 | Timer.scheduledTimer(withTimeInterval: 5, repeats: true) { _ in self.commitGroupoffsets() }
| `- warning: capture of 'self' with non-sendable type 'Consumer' in a '@Sendable' closure; this is an error in the Swift 6 language mode
29 | Timer.scheduledTimer(withTimeInterval: 3, repeats: true) { _ in
30 | self.sendHeartbeat()
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:30:5: warning: capture of 'self' with non-sendable type 'Consumer' in a '@Sendable' closure; this is an error in the Swift 6 language mode
16 | - SeeAlso: `Cluster.getConsumer(topics: groupId:)`
17 | */
18 | public class Consumer {
| `- note: class 'Consumer' does not conform to the 'Sendable' protocol
19 | private let cluster: Cluster
20 | internal var broker: Broker?
:
28 | Timer.scheduledTimer(withTimeInterval: 5, repeats: true) { _ in self.commitGroupoffsets() }
29 | Timer.scheduledTimer(withTimeInterval: 3, repeats: true) { _ in
30 | self.sendHeartbeat()
| `- warning: capture of 'self' with non-sendable type 'Consumer' in a '@Sendable' closure; this is an error in the Swift 6 language mode
31 | }
32 | } else {
/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
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
146 | return Int(crc)
147 | }
[16/28] Compiling Franz CRC32.swift
/host/spi-builder-workspace/Sources/Franz/Connection.swift:101:39: error: cannot find type 'CFReadStream' in scope
99 | private var clientId: String
100 |
101 | private var readStream: Unmanaged<CFReadStream>?
| `- error: cannot find type 'CFReadStream' in scope
102 | private var writeStream: Unmanaged<CFWriteStream>?
103 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:102:40: error: cannot find type 'CFWriteStream' in scope
100 |
101 | private var readStream: Unmanaged<CFReadStream>?
102 | private var writeStream: Unmanaged<CFWriteStream>?
| `- error: cannot find type 'CFWriteStream' in scope
103 |
104 | private var inputStream: InputStream?
/host/spi-builder-workspace/Sources/Franz/Connection.swift:112:36: error: cannot find type 'DispatchQueue' in scope
110 | private let responseCorrelationIdSize: Int32 = 4
111 |
112 | private var _inputStreamQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
113 | private var _outputStreamQueue: DispatchQueue
114 | private var _writeRequestBlocks = [()->()]()
/host/spi-builder-workspace/Sources/Franz/Connection.swift:113:37: error: cannot find type 'DispatchQueue' in scope
111 |
112 | private var _inputStreamQueue: DispatchQueue
113 | private var _outputStreamQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
114 | private var _writeRequestBlocks = [()->()]()
115 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:122:29: error: cannot find 'DispatchQueue' in scope
120 | self.port = port
121 |
122 | _inputStreamQueue = DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
123 | label: "\(self.ipv4).\(self.port).input.stream.franz", attributes: []
124 | )
/host/spi-builder-workspace/Sources/Franz/Connection.swift:126:30: error: cannot find 'DispatchQueue' in scope
124 | )
125 |
126 | _outputStreamQueue = DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
127 | label: "\(self.ipv4).\(self.port).output.stream.franz", attributes: []
128 | )
/host/spi-builder-workspace/Sources/Franz/Connection.swift:132:9: error: cannot find 'CFStreamCreatePairWithSocketToHost' in scope
130 | super.init()
131 |
132 | CFStreamCreatePairWithSocketToHost(
| `- error: cannot find 'CFStreamCreatePairWithSocketToHost' in scope
133 | kCFAllocatorDefault,
134 | ipv4 as CFString,
/host/spi-builder-workspace/Sources/Franz/Connection.swift:133:13: error: cannot find 'kCFAllocatorDefault' in scope
131 |
132 | CFStreamCreatePairWithSocketToHost(
133 | kCFAllocatorDefault,
| `- error: cannot find 'kCFAllocatorDefault' in scope
134 | ipv4 as CFString,
135 | UInt32(port),
/host/spi-builder-workspace/Sources/Franz/Connection.swift:134:21: error: cannot find type 'CFString' in scope
132 | CFStreamCreatePairWithSocketToHost(
133 | kCFAllocatorDefault,
134 | ipv4 as CFString,
| `- error: cannot find type 'CFString' in scope
135 | UInt32(port),
136 | &readStream,
/host/spi-builder-workspace/Sources/Franz/Connection.swift:143:3: error: cannot find 'DispatchQueue' in scope
141 | outputStream = writeStream?.takeUnretainedValue()
142 |
143 | DispatchQueue(label: "FranzConnectionQueue").async {
| `- error: cannot find 'DispatchQueue' in scope
144 | self.inputStream?.delegate = self
145 | self.inputStream?.schedule(
/host/spi-builder-workspace/Sources/Franz/Connection.swift:147:14: error: cannot find 'RunLoopMode' in scope
145 | self.inputStream?.schedule(
146 | in: RunLoop.current,
147 | forMode: RunLoopMode.defaultRunLoopMode
| `- error: cannot find 'RunLoopMode' in scope
148 | )
149 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:153:14: error: cannot find 'RunLoopMode' in scope
151 | self.outputStream?.schedule(
152 | in: RunLoop.current,
153 | forMode: RunLoopMode.defaultRunLoopMode
| `- error: cannot find 'RunLoopMode' in scope
154 | )
155 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:225:23: error: cannot find 'DispatchWorkItem' in scope
223 | _requestCallbacks[request.correlationId] = requestCallback
224 | }
225 | let dispatchBlock = DispatchWorkItem(qos: .unspecified, flags: []) {
| `- error: cannot find 'DispatchWorkItem' in scope
226 | //print("\tBeginning Output Stream Write")
227 | if let stream = self.outputStream {
/host/spi-builder-workspace/Sources/Franz/Connection.swift:225:46: error: cannot infer contextual base in reference to member 'unspecified'
223 | _requestCallbacks[request.correlationId] = requestCallback
224 | }
225 | let dispatchBlock = DispatchWorkItem(qos: .unspecified, flags: []) {
| `- error: cannot infer contextual base in reference to member 'unspecified'
226 | //print("\tBeginning Output Stream Write")
227 | if let stream = self.outputStream {
/host/spi-builder-workspace/Sources/Franz/Connection.swift:262:23: warning: result of call to 'read(_:maxLength:)' is unused
260 | var buffer = Array<UInt8>(repeating: 0, count: Int(length))
261 | if activeInputStream.hasBytesAvailable {
262 | activeInputStream.read(&buffer, maxLength: Int(length))
| `- warning: result of call to 'read(_:maxLength:)' is unused
263 | } else {
264 | throw ConnectionError.bytesNoLongerAvailable
/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 | internal init(cluster: Cluster, groupId: String) {
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:39:28: error: cannot find 'DispatchQueue' in scope
37 | }
38 |
39 | private let listenQueue = DispatchQueue(label: "FranzConsumerListenQueue", attributes: .concurrent)
| `- error: cannot find 'DispatchQueue' in scope
40 |
41 | var offsetsToCommit = [TopicName: [PartitionId: (Offset, OffsetMetadata?)]]()
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:39:90: error: cannot infer contextual base in reference to member 'concurrent'
37 | }
38 |
39 | private let listenQueue = DispatchQueue(label: "FranzConsumerListenQueue", attributes: .concurrent)
| `- error: cannot infer contextual base in reference to member 'concurrent'
40 |
41 | var offsetsToCommit = [TopicName: [PartitionId: (Offset, OffsetMetadata?)]]()
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:42:3: error: Objective-C interoperability is disabled
40 |
41 | var offsetsToCommit = [TopicName: [PartitionId: (Offset, OffsetMetadata?)]]()
42 | @objc private func commitGroupoffsets() {
| `- error: Objective-C interoperability is disabled
43 | guard let groupId = self.membership?.group.id, let broker = self.broker else { return }
44 | broker.commitGroupOffset(groupId: groupId, topics: offsetsToCommit, clientId: cluster.clientId)
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:47:3: error: Objective-C interoperability is disabled
45 | }
46 |
47 | @objc private func sendHeartbeat() {
| `- error: Objective-C interoperability is disabled
48 | guard let groupId = self.membership?.group.id,
49 | let generationId = self.membership?.group.generationId,
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:28:10: warning: result of call to 'scheduledTimer(withTimeInterval:repeats:block:)' is unused
26 |
27 | if #available(OSX 10.12, iOS 10, tvOS 10, watchOS 3, *) {
28 | Timer.scheduledTimer(withTimeInterval: 5, repeats: true) { _ in self.commitGroupoffsets() }
| `- warning: result of call to 'scheduledTimer(withTimeInterval:repeats:block:)' is unused
29 | Timer.scheduledTimer(withTimeInterval: 3, repeats: true) { _ in
30 | self.sendHeartbeat()
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:29:10: warning: result of call to 'scheduledTimer(withTimeInterval:repeats:block:)' is unused
27 | if #available(OSX 10.12, iOS 10, tvOS 10, watchOS 3, *) {
28 | Timer.scheduledTimer(withTimeInterval: 5, repeats: true) { _ in self.commitGroupoffsets() }
29 | Timer.scheduledTimer(withTimeInterval: 3, repeats: true) { _ in
| `- warning: result of call to 'scheduledTimer(withTimeInterval:repeats:block:)' is unused
30 | self.sendHeartbeat()
31 | }
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:34:66: error: '#selector' can only be used with the Objective-C runtime
32 | } else {
33 | // Fallback on earlier versions
34 | Timer.scheduledTimer(timeInterval: 5, target: self, selector: #selector(commitGroupoffsets), userInfo: nil, repeats: true)
| `- error: '#selector' can only be used with the Objective-C runtime
35 | Timer.scheduledTimer(timeInterval: 3, target: self, selector: #selector(sendHeartbeat), userInfo: nil, repeats: true)
36 | }
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:35:66: error: '#selector' can only be used with the Objective-C runtime
33 | // Fallback on earlier versions
34 | Timer.scheduledTimer(timeInterval: 5, target: self, selector: #selector(commitGroupoffsets), userInfo: nil, repeats: true)
35 | Timer.scheduledTimer(timeInterval: 3, target: self, selector: #selector(sendHeartbeat), userInfo: nil, repeats: true)
| `- error: '#selector' can only be used with the Objective-C runtime
36 | }
37 | }
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:28:68: warning: capture of 'self' with non-sendable type 'Consumer' in a '@Sendable' closure; this is an error in the Swift 6 language mode
16 | - SeeAlso: `Cluster.getConsumer(topics: groupId:)`
17 | */
18 | public class Consumer {
| `- note: class 'Consumer' does not conform to the 'Sendable' protocol
19 | private let cluster: Cluster
20 | internal var broker: Broker?
:
26 |
27 | if #available(OSX 10.12, iOS 10, tvOS 10, watchOS 3, *) {
28 | Timer.scheduledTimer(withTimeInterval: 5, repeats: true) { _ in self.commitGroupoffsets() }
| `- warning: capture of 'self' with non-sendable type 'Consumer' in a '@Sendable' closure; this is an error in the Swift 6 language mode
29 | Timer.scheduledTimer(withTimeInterval: 3, repeats: true) { _ in
30 | self.sendHeartbeat()
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:30:5: warning: capture of 'self' with non-sendable type 'Consumer' in a '@Sendable' closure; this is an error in the Swift 6 language mode
16 | - SeeAlso: `Cluster.getConsumer(topics: groupId:)`
17 | */
18 | public class Consumer {
| `- note: class 'Consumer' does not conform to the 'Sendable' protocol
19 | private let cluster: Cluster
20 | internal var broker: Broker?
:
28 | Timer.scheduledTimer(withTimeInterval: 5, repeats: true) { _ in self.commitGroupoffsets() }
29 | Timer.scheduledTimer(withTimeInterval: 3, repeats: true) { _ in
30 | self.sendHeartbeat()
| `- warning: capture of 'self' with non-sendable type 'Consumer' in a '@Sendable' closure; this is an error in the Swift 6 language mode
31 | }
32 | } else {
/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
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
146 | return Int(crc)
147 | }
[17/28] Compiling Franz GroupCoordinatorAPI.swift
/host/spi-builder-workspace/Sources/Franz/GroupMembershipAPI.swift:411:24: warning: generic parameter 'T' shadows generic parameter from outer scope with the same name; this is an error in the Swift 6 language mode
361 | typealias MemberId = String
362 |
363 | class SyncGroupRequestMessage<T: KafkaMetadata>: KafkaType {
| `- note: 'T' previously declared here
364 |
365 | private var _groupId: String
:
409 |
410 |
411 | class 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
412 |
413 | let memberId: String
[18/28] Compiling Franz GroupMembershipAPI.swift
/host/spi-builder-workspace/Sources/Franz/GroupMembershipAPI.swift:411:24: warning: generic parameter 'T' shadows generic parameter from outer scope with the same name; this is an error in the Swift 6 language mode
361 | typealias MemberId = String
362 |
363 | class SyncGroupRequestMessage<T: KafkaMetadata>: KafkaType {
| `- note: 'T' previously declared here
364 |
365 | private var _groupId: String
:
409 |
410 |
411 | class 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
412 |
413 | let memberId: String
[19/28] Compiling Franz KafkaProtocol.swift
/host/spi-builder-workspace/Sources/Franz/GroupMembershipAPI.swift:411:24: warning: generic parameter 'T' shadows generic parameter from outer scope with the same name; this is an error in the Swift 6 language mode
361 | typealias MemberId = String
362 |
363 | class SyncGroupRequestMessage<T: KafkaMetadata>: KafkaType {
| `- note: 'T' previously declared here
364 |
365 | private var _groupId: String
:
409 |
410 |
411 | class 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
412 |
413 | let memberId: String
[20/28] Compiling Franz OffsetFetchAPI.swift
/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/28] Compiling Franz OldConsumers.swift
/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/28] Compiling Franz Partition.swift
/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 | }
[23/28] Compiling Franz MetadataAPI.swift
/host/spi-builder-workspace/Sources/Franz/Broker.swift:70:39: error: cannot find type 'DispatchQueue' in scope
68 | private var _readQueues = [Int32: DispatchQueue]()
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
71 | return DispatchQueue(
72 | label: "metadata.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:77:43: error: cannot find type 'DispatchQueue' in scope
75 | }()
76 |
77 | private lazy var _metadataWriteQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
78 | return DispatchQueue(
79 | label: "metadata.write.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:84:39: error: cannot find type 'DispatchQueue' in scope
82 | }()
83 |
84 | private lazy var _adminReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
85 | return DispatchQueue(
86 | label: "admin.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:91:47: error: cannot find type 'DispatchQueue' in scope
89 | }()
90 |
91 | private lazy var _groupCoordinationQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
92 | return DispatchQueue(
93 | label: "group.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:39: error: cannot find 'DispatchQueue' in scope
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot find 'DispatchQueue' in scope
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:31: error: cannot call value of non-function type '[AnyHashable : Any]'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot call value of non-function type '[AnyHashable : Any]'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:32: error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
[24/28] Compiling Franz OffsetAPI.swift
/host/spi-builder-workspace/Sources/Franz/Broker.swift:70:39: error: cannot find type 'DispatchQueue' in scope
68 | private var _readQueues = [Int32: DispatchQueue]()
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
71 | return DispatchQueue(
72 | label: "metadata.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:77:43: error: cannot find type 'DispatchQueue' in scope
75 | }()
76 |
77 | private lazy var _metadataWriteQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
78 | return DispatchQueue(
79 | label: "metadata.write.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:84:39: error: cannot find type 'DispatchQueue' in scope
82 | }()
83 |
84 | private lazy var _adminReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
85 | return DispatchQueue(
86 | label: "admin.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:91:47: error: cannot find type 'DispatchQueue' in scope
89 | }()
90 |
91 | private lazy var _groupCoordinationQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
92 | return DispatchQueue(
93 | label: "group.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:39: error: cannot find 'DispatchQueue' in scope
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot find 'DispatchQueue' in scope
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:31: error: cannot call value of non-function type '[AnyHashable : Any]'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot call value of non-function type '[AnyHashable : Any]'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:32: error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
[25/28] Compiling Franz OffsetCommitAPI.swift
/host/spi-builder-workspace/Sources/Franz/Broker.swift:70:39: error: cannot find type 'DispatchQueue' in scope
68 | private var _readQueues = [Int32: DispatchQueue]()
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
71 | return DispatchQueue(
72 | label: "metadata.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:77:43: error: cannot find type 'DispatchQueue' in scope
75 | }()
76 |
77 | private lazy var _metadataWriteQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
78 | return DispatchQueue(
79 | label: "metadata.write.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:84:39: error: cannot find type 'DispatchQueue' in scope
82 | }()
83 |
84 | private lazy var _adminReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
85 | return DispatchQueue(
86 | label: "admin.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:91:47: error: cannot find type 'DispatchQueue' in scope
89 | }()
90 |
91 | private lazy var _groupCoordinationQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
92 | return DispatchQueue(
93 | label: "group.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:39: error: cannot find 'DispatchQueue' in scope
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot find 'DispatchQueue' in scope
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:31: error: cannot call value of non-function type '[AnyHashable : Any]'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot call value of non-function type '[AnyHashable : Any]'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:32: error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
[26/28] Compiling Franz Enumerations.swift
/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/Broker.swift:70:39: error: cannot find type 'DispatchQueue' in scope
68 | private var _readQueues = [Int32: DispatchQueue]()
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
71 | return DispatchQueue(
72 | label: "metadata.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:77:43: error: cannot find type 'DispatchQueue' in scope
75 | }()
76 |
77 | private lazy var _metadataWriteQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
78 | return DispatchQueue(
79 | label: "metadata.write.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:84:39: error: cannot find type 'DispatchQueue' in scope
82 | }()
83 |
84 | private lazy var _adminReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
85 | return DispatchQueue(
86 | label: "admin.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:91:47: error: cannot find type 'DispatchQueue' in scope
89 | }()
90 |
91 | private lazy var _groupCoordinationQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
92 | return DispatchQueue(
93 | label: "group.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:39: error: cannot find 'DispatchQueue' in scope
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot find 'DispatchQueue' in scope
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:31: error: cannot call value of non-function type '[AnyHashable : Any]'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot call value of non-function type '[AnyHashable : Any]'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:32: error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
[27/28] Compiling Franz FetchAPI.swift
/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/Broker.swift:70:39: error: cannot find type 'DispatchQueue' in scope
68 | private var _readQueues = [Int32: DispatchQueue]()
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
71 | return DispatchQueue(
72 | label: "metadata.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:77:43: error: cannot find type 'DispatchQueue' in scope
75 | }()
76 |
77 | private lazy var _metadataWriteQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
78 | return DispatchQueue(
79 | label: "metadata.write.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:84:39: error: cannot find type 'DispatchQueue' in scope
82 | }()
83 |
84 | private lazy var _adminReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
85 | return DispatchQueue(
86 | label: "admin.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:91:47: error: cannot find type 'DispatchQueue' in scope
89 | }()
90 |
91 | private lazy var _groupCoordinationQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
92 | return DispatchQueue(
93 | label: "group.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:39: error: cannot find 'DispatchQueue' in scope
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot find 'DispatchQueue' in scope
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:31: error: cannot call value of non-function type '[AnyHashable : Any]'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot call value of non-function type '[AnyHashable : Any]'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:32: error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
[28/28] Compiling Franz Group.swift
/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/Broker.swift:70:39: error: cannot find type 'DispatchQueue' in scope
68 | private var _readQueues = [Int32: DispatchQueue]()
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
71 | return DispatchQueue(
72 | label: "metadata.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:77:43: error: cannot find type 'DispatchQueue' in scope
75 | }()
76 |
77 | private lazy var _metadataWriteQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
78 | return DispatchQueue(
79 | label: "metadata.write.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:84:39: error: cannot find type 'DispatchQueue' in scope
82 | }()
83 |
84 | private lazy var _adminReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
85 | return DispatchQueue(
86 | label: "admin.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:91:47: error: cannot find type 'DispatchQueue' in scope
89 | }()
90 |
91 | private lazy var _groupCoordinationQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
92 | return DispatchQueue(
93 | label: "group.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:39: error: cannot find 'DispatchQueue' in scope
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot find 'DispatchQueue' in scope
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:31: error: cannot call value of non-function type '[AnyHashable : Any]'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot call value of non-function type '[AnyHashable : Any]'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:32: error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
Running build ...
bash -c docker run --pull=always --rm -v "checkouts-4609320-0":/host -w "$PWD" registry.gitlab.com/finestructure/spi-images:wasm-6.1-latest swift build --swift-sdk wasm32-unknown-wasi 2>&1
wasm-6.1-latest: Pulling from finestructure/spi-images
Digest: sha256:059e0fdbe549369b902c0d423739510ddee50a4a70258d1404125eb9394ef31c
Status: Image is up to date for registry.gitlab.com/finestructure/spi-images:wasm-6.1-latest
[0/1] Planning build
Building for debugging...
[0/1] Write swift-version-24593BA9C3E375BF.txt
error: emit-module command failed with exit code 1 (use -v to see invocation)
[2/24] Emitting module Franz
/host/spi-builder-workspace/Sources/Franz/Broker.swift:70:39: error: cannot find type 'DispatchQueue' in scope
68 | private var _readQueues = [Int32: DispatchQueue]()
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
71 | return DispatchQueue(
72 | label: "metadata.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:77:43: error: cannot find type 'DispatchQueue' in scope
75 | }()
76 |
77 | private lazy var _metadataWriteQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
78 | return DispatchQueue(
79 | label: "metadata.write.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:84:39: error: cannot find type 'DispatchQueue' in scope
82 | }()
83 |
84 | private lazy var _adminReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
85 | return DispatchQueue(
86 | label: "admin.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:91:47: error: cannot find type 'DispatchQueue' in scope
89 | }()
90 |
91 | private lazy var _groupCoordinationQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
92 | return DispatchQueue(
93 | label: "group.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:39: error: cannot find 'DispatchQueue' in scope
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot find 'DispatchQueue' in scope
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:32: error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:31: error: cannot call value of non-function type '[AnyHashable : Any]'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot call value of non-function type '[AnyHashable : Any]'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:552:69: error: cannot find type 'DispatchQueue' in scope
550 | }
551 |
552 | private func getReadQueue(_ topic: String, partition: Int32) -> DispatchQueue {
| `- error: cannot find type 'DispatchQueue' in scope
553 | var readQueue: DispatchQueue
554 | if let pq = _readQueues[partition] {
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:43:29: error: cannot find type 'DispatchQueue' in scope
41 | }
42 |
43 | lazy var dispatchQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
44 | return DispatchQueue(
45 | label: "metadata.cluster.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Connection.swift:101:39: error: cannot find type 'CFReadStream' in scope
99 | private var clientId: String
100 |
101 | private var readStream: Unmanaged<CFReadStream>?
| `- error: cannot find type 'CFReadStream' in scope
102 | private var writeStream: Unmanaged<CFWriteStream>?
103 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:102:40: error: cannot find type 'CFWriteStream' in scope
100 |
101 | private var readStream: Unmanaged<CFReadStream>?
102 | private var writeStream: Unmanaged<CFWriteStream>?
| `- error: cannot find type 'CFWriteStream' in scope
103 |
104 | private var inputStream: InputStream?
/host/spi-builder-workspace/Sources/Franz/Connection.swift:112:36: error: cannot find type 'DispatchQueue' in scope
110 | private let responseCorrelationIdSize: Int32 = 4
111 |
112 | private var _inputStreamQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
113 | private var _outputStreamQueue: DispatchQueue
114 | private var _writeRequestBlocks = [()->()]()
/host/spi-builder-workspace/Sources/Franz/Connection.swift:113:37: error: cannot find type 'DispatchQueue' in scope
111 |
112 | private var _inputStreamQueue: DispatchQueue
113 | private var _outputStreamQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
114 | private var _writeRequestBlocks = [()->()]()
115 |
/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 | internal init(cluster: Cluster, groupId: String) {
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:39:28: error: cannot find 'DispatchQueue' in scope
37 | }
38 |
39 | private let listenQueue = DispatchQueue(label: "FranzConsumerListenQueue", attributes: .concurrent)
| `- error: cannot find 'DispatchQueue' in scope
40 |
41 | var offsetsToCommit = [TopicName: [PartitionId: (Offset, OffsetMetadata?)]]()
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:39:90: error: cannot infer contextual base in reference to member 'concurrent'
37 | }
38 |
39 | private let listenQueue = DispatchQueue(label: "FranzConsumerListenQueue", attributes: .concurrent)
| `- error: cannot infer contextual base in reference to member 'concurrent'
40 |
41 | var offsetsToCommit = [TopicName: [PartitionId: (Offset, OffsetMetadata?)]]()
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:42:3: error: Objective-C interoperability is disabled
40 |
41 | var offsetsToCommit = [TopicName: [PartitionId: (Offset, OffsetMetadata?)]]()
42 | @objc private func commitGroupoffsets() {
| `- error: Objective-C interoperability is disabled
43 | guard let groupId = self.membership?.group.id, let broker = self.broker else { return }
44 | broker.commitGroupOffset(groupId: groupId, topics: offsetsToCommit, clientId: cluster.clientId)
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:47:3: error: Objective-C interoperability is disabled
45 | }
46 |
47 | @objc private func sendHeartbeat() {
| `- error: Objective-C interoperability is disabled
48 | guard let groupId = self.membership?.group.id,
49 | 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
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
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/GroupMembershipAPI.swift:411:24: warning: generic parameter 'T' shadows generic parameter from outer scope with the same name; this is an error in the Swift 6 language mode
361 | typealias MemberId = String
362 |
363 | class SyncGroupRequestMessage<T: KafkaMetadata>: KafkaType {
| `- note: 'T' previously declared here
364 |
365 | private var _groupId: String
:
409 |
410 |
411 | class 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
412 |
413 | let memberId: String
/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 |
/host/spi-builder-workspace/Sources/Franz/Variables.swift:11:16: error: cannot find type 'DispatchQueue' in scope
9 | import Foundation
10 |
11 | var MainQueue: DispatchQueue {
| `- error: cannot find type 'DispatchQueue' in scope
12 | return DispatchQueue.main
13 | }
/host/spi-builder-workspace/Sources/Franz/Variables.swift:15:27: error: cannot find type 'DispatchQueue' in scope
13 | }
14 |
15 | var UserInteractiveQueue: DispatchQueue {
| `- error: cannot find type 'DispatchQueue' in scope
16 | return DispatchQueue.global(qos: DispatchQoS.QoSClass.userInteractive)
17 | }
/host/spi-builder-workspace/Sources/Franz/Variables.swift:19:25: error: cannot find type 'DispatchQueue' in scope
17 | }
18 |
19 | var UserInitiatedQueue: DispatchQueue {
| `- error: cannot find type 'DispatchQueue' in scope
20 | return DispatchQueue.global(qos: DispatchQoS.QoSClass.userInitiated)
21 | }
/host/spi-builder-workspace/Sources/Franz/Variables.swift:23:19: error: cannot find type 'DispatchQueue' in scope
21 | }
22 |
23 | var UtilityQueue: DispatchQueue {
| `- error: cannot find type 'DispatchQueue' in scope
24 | return DispatchQueue.global(qos: DispatchQoS.QoSClass.utility)
25 | }
/host/spi-builder-workspace/Sources/Franz/Variables.swift:27:22: error: cannot find type 'DispatchQueue' in scope
25 | }
26 |
27 | var BackgroundQueue: DispatchQueue {
| `- error: cannot find type 'DispatchQueue' in scope
28 | return DispatchQueue.global(qos: DispatchQoS.QoSClass.background)
29 | }
[3/27] Compiling Franz OffsetFetchAPI.swift
/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 | }
[4/27] Compiling Franz OldConsumers.swift
/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 | }
[5/27] Compiling Franz Partition.swift
/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 | }
[6/27] Compiling Franz MetadataAPI.swift
/host/spi-builder-workspace/Sources/Franz/Broker.swift:70:39: error: cannot find type 'DispatchQueue' in scope
68 | private var _readQueues = [Int32: DispatchQueue]()
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
71 | return DispatchQueue(
72 | label: "metadata.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:77:43: error: cannot find type 'DispatchQueue' in scope
75 | }()
76 |
77 | private lazy var _metadataWriteQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
78 | return DispatchQueue(
79 | label: "metadata.write.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:84:39: error: cannot find type 'DispatchQueue' in scope
82 | }()
83 |
84 | private lazy var _adminReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
85 | return DispatchQueue(
86 | label: "admin.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:91:47: error: cannot find type 'DispatchQueue' in scope
89 | }()
90 |
91 | private lazy var _groupCoordinationQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
92 | return DispatchQueue(
93 | label: "group.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:39: error: cannot find 'DispatchQueue' in scope
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot find 'DispatchQueue' in scope
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:31: error: cannot call value of non-function type '[AnyHashable : Any]'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot call value of non-function type '[AnyHashable : Any]'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:32: error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
[7/27] Compiling Franz OffsetAPI.swift
/host/spi-builder-workspace/Sources/Franz/Broker.swift:70:39: error: cannot find type 'DispatchQueue' in scope
68 | private var _readQueues = [Int32: DispatchQueue]()
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
71 | return DispatchQueue(
72 | label: "metadata.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:77:43: error: cannot find type 'DispatchQueue' in scope
75 | }()
76 |
77 | private lazy var _metadataWriteQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
78 | return DispatchQueue(
79 | label: "metadata.write.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:84:39: error: cannot find type 'DispatchQueue' in scope
82 | }()
83 |
84 | private lazy var _adminReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
85 | return DispatchQueue(
86 | label: "admin.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:91:47: error: cannot find type 'DispatchQueue' in scope
89 | }()
90 |
91 | private lazy var _groupCoordinationQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
92 | return DispatchQueue(
93 | label: "group.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:39: error: cannot find 'DispatchQueue' in scope
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot find 'DispatchQueue' in scope
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:31: error: cannot call value of non-function type '[AnyHashable : Any]'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot call value of non-function type '[AnyHashable : Any]'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:32: error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
[8/27] Compiling Franz OffsetCommitAPI.swift
/host/spi-builder-workspace/Sources/Franz/Broker.swift:70:39: error: cannot find type 'DispatchQueue' in scope
68 | private var _readQueues = [Int32: DispatchQueue]()
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
71 | return DispatchQueue(
72 | label: "metadata.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:77:43: error: cannot find type 'DispatchQueue' in scope
75 | }()
76 |
77 | private lazy var _metadataWriteQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
78 | return DispatchQueue(
79 | label: "metadata.write.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:84:39: error: cannot find type 'DispatchQueue' in scope
82 | }()
83 |
84 | private lazy var _adminReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
85 | return DispatchQueue(
86 | label: "admin.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:91:47: error: cannot find type 'DispatchQueue' in scope
89 | }()
90 |
91 | private lazy var _groupCoordinationQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
92 | return DispatchQueue(
93 | label: "group.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:39: error: cannot find 'DispatchQueue' in scope
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot find 'DispatchQueue' in scope
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:31: error: cannot call value of non-function type '[AnyHashable : Any]'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot call value of non-function type '[AnyHashable : Any]'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:32: error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
[9/27] Compiling Franz ProduceAPI.swift
/host/spi-builder-workspace/Sources/Franz/Variables.swift:11:16: error: cannot find type 'DispatchQueue' in scope
9 | import Foundation
10 |
11 | var MainQueue: DispatchQueue {
| `- error: cannot find type 'DispatchQueue' in scope
12 | return DispatchQueue.main
13 | }
/host/spi-builder-workspace/Sources/Franz/Variables.swift:15:27: error: cannot find type 'DispatchQueue' in scope
13 | }
14 |
15 | var UserInteractiveQueue: DispatchQueue {
| `- error: cannot find type 'DispatchQueue' in scope
16 | return DispatchQueue.global(qos: DispatchQoS.QoSClass.userInteractive)
17 | }
/host/spi-builder-workspace/Sources/Franz/Variables.swift:19:25: error: cannot find type 'DispatchQueue' in scope
17 | }
18 |
19 | var UserInitiatedQueue: DispatchQueue {
| `- error: cannot find type 'DispatchQueue' in scope
20 | return DispatchQueue.global(qos: DispatchQoS.QoSClass.userInitiated)
21 | }
/host/spi-builder-workspace/Sources/Franz/Variables.swift:23:19: error: cannot find type 'DispatchQueue' in scope
21 | }
22 |
23 | var UtilityQueue: DispatchQueue {
| `- error: cannot find type 'DispatchQueue' in scope
24 | return DispatchQueue.global(qos: DispatchQoS.QoSClass.utility)
25 | }
/host/spi-builder-workspace/Sources/Franz/Variables.swift:27:22: error: cannot find type 'DispatchQueue' in scope
25 | }
26 |
27 | var BackgroundQueue: DispatchQueue {
| `- error: cannot find type 'DispatchQueue' in scope
28 | return DispatchQueue.global(qos: DispatchQoS.QoSClass.background)
29 | }
[10/27] Compiling Franz Topic.swift
/host/spi-builder-workspace/Sources/Franz/Variables.swift:11:16: error: cannot find type 'DispatchQueue' in scope
9 | import Foundation
10 |
11 | var MainQueue: DispatchQueue {
| `- error: cannot find type 'DispatchQueue' in scope
12 | return DispatchQueue.main
13 | }
/host/spi-builder-workspace/Sources/Franz/Variables.swift:15:27: error: cannot find type 'DispatchQueue' in scope
13 | }
14 |
15 | var UserInteractiveQueue: DispatchQueue {
| `- error: cannot find type 'DispatchQueue' in scope
16 | return DispatchQueue.global(qos: DispatchQoS.QoSClass.userInteractive)
17 | }
/host/spi-builder-workspace/Sources/Franz/Variables.swift:19:25: error: cannot find type 'DispatchQueue' in scope
17 | }
18 |
19 | var UserInitiatedQueue: DispatchQueue {
| `- error: cannot find type 'DispatchQueue' in scope
20 | return DispatchQueue.global(qos: DispatchQoS.QoSClass.userInitiated)
21 | }
/host/spi-builder-workspace/Sources/Franz/Variables.swift:23:19: error: cannot find type 'DispatchQueue' in scope
21 | }
22 |
23 | var UtilityQueue: DispatchQueue {
| `- error: cannot find type 'DispatchQueue' in scope
24 | return DispatchQueue.global(qos: DispatchQoS.QoSClass.utility)
25 | }
/host/spi-builder-workspace/Sources/Franz/Variables.swift:27:22: error: cannot find type 'DispatchQueue' in scope
25 | }
26 |
27 | var BackgroundQueue: DispatchQueue {
| `- error: cannot find type 'DispatchQueue' in scope
28 | return DispatchQueue.global(qos: DispatchQoS.QoSClass.background)
29 | }
[11/27] Compiling Franz Variables.swift
/host/spi-builder-workspace/Sources/Franz/Variables.swift:11:16: error: cannot find type 'DispatchQueue' in scope
9 | import Foundation
10 |
11 | var MainQueue: DispatchQueue {
| `- error: cannot find type 'DispatchQueue' in scope
12 | return DispatchQueue.main
13 | }
/host/spi-builder-workspace/Sources/Franz/Variables.swift:15:27: error: cannot find type 'DispatchQueue' in scope
13 | }
14 |
15 | var UserInteractiveQueue: DispatchQueue {
| `- error: cannot find type 'DispatchQueue' in scope
16 | return DispatchQueue.global(qos: DispatchQoS.QoSClass.userInteractive)
17 | }
/host/spi-builder-workspace/Sources/Franz/Variables.swift:19:25: error: cannot find type 'DispatchQueue' in scope
17 | }
18 |
19 | var UserInitiatedQueue: DispatchQueue {
| `- error: cannot find type 'DispatchQueue' in scope
20 | return DispatchQueue.global(qos: DispatchQoS.QoSClass.userInitiated)
21 | }
/host/spi-builder-workspace/Sources/Franz/Variables.swift:23:19: error: cannot find type 'DispatchQueue' in scope
21 | }
22 |
23 | var UtilityQueue: DispatchQueue {
| `- error: cannot find type 'DispatchQueue' in scope
24 | return DispatchQueue.global(qos: DispatchQoS.QoSClass.utility)
25 | }
/host/spi-builder-workspace/Sources/Franz/Variables.swift:27:22: error: cannot find type 'DispatchQueue' in scope
25 | }
26 |
27 | var BackgroundQueue: DispatchQueue {
| `- error: cannot find type 'DispatchQueue' in scope
28 | return DispatchQueue.global(qos: DispatchQoS.QoSClass.background)
29 | }
[12/27] Compiling Franz KafkaRequest.swift
[13/27] Compiling Franz KafkaResponse.swift
[14/27] Compiling Franz MessageSet.swift
[15/27] Compiling Franz AdminAPI.swift
/host/spi-builder-workspace/Sources/Franz/Broker.swift:70:39: error: cannot find type 'DispatchQueue' in scope
68 | private var _readQueues = [Int32: DispatchQueue]()
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
71 | return DispatchQueue(
72 | label: "metadata.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:77:43: error: cannot find type 'DispatchQueue' in scope
75 | }()
76 |
77 | private lazy var _metadataWriteQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
78 | return DispatchQueue(
79 | label: "metadata.write.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:84:39: error: cannot find type 'DispatchQueue' in scope
82 | }()
83 |
84 | private lazy var _adminReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
85 | return DispatchQueue(
86 | label: "admin.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:91:47: error: cannot find type 'DispatchQueue' in scope
89 | }()
90 |
91 | private lazy var _groupCoordinationQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
92 | return DispatchQueue(
93 | label: "group.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:39: error: cannot find 'DispatchQueue' in scope
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot find 'DispatchQueue' in scope
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:32: error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:31: error: cannot call value of non-function type '[AnyHashable : Any]'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot call value of non-function type '[AnyHashable : Any]'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:552:69: error: cannot find type 'DispatchQueue' in scope
550 | }
551 |
552 | private func getReadQueue(_ topic: String, partition: Int32) -> DispatchQueue {
| `- error: cannot find type 'DispatchQueue' in scope
553 | var readQueue: DispatchQueue
554 | if let pq = _readQueues[partition] {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:553:24: error: cannot find type 'DispatchQueue' in scope
551 |
552 | private func getReadQueue(_ topic: String, partition: Int32) -> DispatchQueue {
553 | var readQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
554 | if let pq = _readQueues[partition] {
555 | readQueue = pq
/host/spi-builder-workspace/Sources/Franz/Broker.swift:557:38: error: cannot find 'DispatchQueue' in scope
555 | readQueue = pq
556 | } else {
557 | _readQueues[partition] = DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
558 | label: "\(partition).\(topic).read.stream.franz",
559 | attributes: DispatchQueue.Attributes.concurrent
/host/spi-builder-workspace/Sources/Franz/Broker.swift:559:29: error: cannot find 'DispatchQueue' in scope
557 | _readQueues[partition] = DispatchQueue(
558 | label: "\(partition).\(topic).read.stream.franz",
559 | attributes: DispatchQueue.Attributes.concurrent
| `- error: cannot find 'DispatchQueue' in scope
560 | )
561 | readQueue = _readQueues[partition]!
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:43:29: error: cannot find type 'DispatchQueue' in scope
41 | }
42 |
43 | lazy var dispatchQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
44 | return DispatchQueue(
45 | label: "metadata.cluster.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:334:3: error: cannot find 'DispatchQueue' in scope
332 | public func getConsumer(topics: [TopicName], groupId: String) -> Consumer {
333 | let consumer = Consumer(cluster: self, groupId: groupId)
334 | DispatchQueue(label: "FranzConsumerGetQueue").async {
| `- error: cannot find 'DispatchQueue' in scope
335 | self.joinGroup(id: groupId, topics: topics, callback: { broker, membership in
336 | consumer.broker = broker
/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 | internal init(cluster: Cluster, groupId: String) {
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:375:33: error: cannot find 'DispatchWorkItem' in scope
373 |
374 | for (_, broker) in _brokers {
375 | let dispatchBlock = DispatchWorkItem(qos: .unspecified, flags: []) {
| `- error: cannot find 'DispatchWorkItem' in scope
376 |
377 | var handleGetTopicMetadata: ((MetadataResponse) -> Void)!
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:375:56: error: cannot infer contextual base in reference to member 'unspecified'
373 |
374 | for (_, broker) in _brokers {
375 | let dispatchBlock = DispatchWorkItem(qos: .unspecified, flags: []) {
| `- error: cannot infer contextual base in reference to member 'unspecified'
376 |
377 | var handleGetTopicMetadata: ((MetadataResponse) -> Void)!
[16/27] Compiling Franz Assignment.swift
/host/spi-builder-workspace/Sources/Franz/Broker.swift:70:39: error: cannot find type 'DispatchQueue' in scope
68 | private var _readQueues = [Int32: DispatchQueue]()
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
71 | return DispatchQueue(
72 | label: "metadata.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:77:43: error: cannot find type 'DispatchQueue' in scope
75 | }()
76 |
77 | private lazy var _metadataWriteQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
78 | return DispatchQueue(
79 | label: "metadata.write.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:84:39: error: cannot find type 'DispatchQueue' in scope
82 | }()
83 |
84 | private lazy var _adminReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
85 | return DispatchQueue(
86 | label: "admin.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:91:47: error: cannot find type 'DispatchQueue' in scope
89 | }()
90 |
91 | private lazy var _groupCoordinationQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
92 | return DispatchQueue(
93 | label: "group.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:39: error: cannot find 'DispatchQueue' in scope
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot find 'DispatchQueue' in scope
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:32: error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:31: error: cannot call value of non-function type '[AnyHashable : Any]'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot call value of non-function type '[AnyHashable : Any]'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:552:69: error: cannot find type 'DispatchQueue' in scope
550 | }
551 |
552 | private func getReadQueue(_ topic: String, partition: Int32) -> DispatchQueue {
| `- error: cannot find type 'DispatchQueue' in scope
553 | var readQueue: DispatchQueue
554 | if let pq = _readQueues[partition] {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:553:24: error: cannot find type 'DispatchQueue' in scope
551 |
552 | private func getReadQueue(_ topic: String, partition: Int32) -> DispatchQueue {
553 | var readQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
554 | if let pq = _readQueues[partition] {
555 | readQueue = pq
/host/spi-builder-workspace/Sources/Franz/Broker.swift:557:38: error: cannot find 'DispatchQueue' in scope
555 | readQueue = pq
556 | } else {
557 | _readQueues[partition] = DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
558 | label: "\(partition).\(topic).read.stream.franz",
559 | attributes: DispatchQueue.Attributes.concurrent
/host/spi-builder-workspace/Sources/Franz/Broker.swift:559:29: error: cannot find 'DispatchQueue' in scope
557 | _readQueues[partition] = DispatchQueue(
558 | label: "\(partition).\(topic).read.stream.franz",
559 | attributes: DispatchQueue.Attributes.concurrent
| `- error: cannot find 'DispatchQueue' in scope
560 | )
561 | readQueue = _readQueues[partition]!
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:43:29: error: cannot find type 'DispatchQueue' in scope
41 | }
42 |
43 | lazy var dispatchQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
44 | return DispatchQueue(
45 | label: "metadata.cluster.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:334:3: error: cannot find 'DispatchQueue' in scope
332 | public func getConsumer(topics: [TopicName], groupId: String) -> Consumer {
333 | let consumer = Consumer(cluster: self, groupId: groupId)
334 | DispatchQueue(label: "FranzConsumerGetQueue").async {
| `- error: cannot find 'DispatchQueue' in scope
335 | self.joinGroup(id: groupId, topics: topics, callback: { broker, membership in
336 | consumer.broker = broker
/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 | internal init(cluster: Cluster, groupId: String) {
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:375:33: error: cannot find 'DispatchWorkItem' in scope
373 |
374 | for (_, broker) in _brokers {
375 | let dispatchBlock = DispatchWorkItem(qos: .unspecified, flags: []) {
| `- error: cannot find 'DispatchWorkItem' in scope
376 |
377 | var handleGetTopicMetadata: ((MetadataResponse) -> Void)!
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:375:56: error: cannot infer contextual base in reference to member 'unspecified'
373 |
374 | for (_, broker) in _brokers {
375 | let dispatchBlock = DispatchWorkItem(qos: .unspecified, flags: []) {
| `- error: cannot infer contextual base in reference to member 'unspecified'
376 |
377 | var handleGetTopicMetadata: ((MetadataResponse) -> Void)!
[17/27] Compiling Franz Broker.swift
/host/spi-builder-workspace/Sources/Franz/Broker.swift:70:39: error: cannot find type 'DispatchQueue' in scope
68 | private var _readQueues = [Int32: DispatchQueue]()
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
71 | return DispatchQueue(
72 | label: "metadata.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:77:43: error: cannot find type 'DispatchQueue' in scope
75 | }()
76 |
77 | private lazy var _metadataWriteQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
78 | return DispatchQueue(
79 | label: "metadata.write.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:84:39: error: cannot find type 'DispatchQueue' in scope
82 | }()
83 |
84 | private lazy var _adminReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
85 | return DispatchQueue(
86 | label: "admin.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:91:47: error: cannot find type 'DispatchQueue' in scope
89 | }()
90 |
91 | private lazy var _groupCoordinationQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
92 | return DispatchQueue(
93 | label: "group.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:39: error: cannot find 'DispatchQueue' in scope
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot find 'DispatchQueue' in scope
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:32: error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:31: error: cannot call value of non-function type '[AnyHashable : Any]'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot call value of non-function type '[AnyHashable : Any]'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:552:69: error: cannot find type 'DispatchQueue' in scope
550 | }
551 |
552 | private func getReadQueue(_ topic: String, partition: Int32) -> DispatchQueue {
| `- error: cannot find type 'DispatchQueue' in scope
553 | var readQueue: DispatchQueue
554 | if let pq = _readQueues[partition] {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:553:24: error: cannot find type 'DispatchQueue' in scope
551 |
552 | private func getReadQueue(_ topic: String, partition: Int32) -> DispatchQueue {
553 | var readQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
554 | if let pq = _readQueues[partition] {
555 | readQueue = pq
/host/spi-builder-workspace/Sources/Franz/Broker.swift:557:38: error: cannot find 'DispatchQueue' in scope
555 | readQueue = pq
556 | } else {
557 | _readQueues[partition] = DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
558 | label: "\(partition).\(topic).read.stream.franz",
559 | attributes: DispatchQueue.Attributes.concurrent
/host/spi-builder-workspace/Sources/Franz/Broker.swift:559:29: error: cannot find 'DispatchQueue' in scope
557 | _readQueues[partition] = DispatchQueue(
558 | label: "\(partition).\(topic).read.stream.franz",
559 | attributes: DispatchQueue.Attributes.concurrent
| `- error: cannot find 'DispatchQueue' in scope
560 | )
561 | readQueue = _readQueues[partition]!
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:43:29: error: cannot find type 'DispatchQueue' in scope
41 | }
42 |
43 | lazy var dispatchQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
44 | return DispatchQueue(
45 | label: "metadata.cluster.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:334:3: error: cannot find 'DispatchQueue' in scope
332 | public func getConsumer(topics: [TopicName], groupId: String) -> Consumer {
333 | let consumer = Consumer(cluster: self, groupId: groupId)
334 | DispatchQueue(label: "FranzConsumerGetQueue").async {
| `- error: cannot find 'DispatchQueue' in scope
335 | self.joinGroup(id: groupId, topics: topics, callback: { broker, membership in
336 | consumer.broker = broker
/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 | internal init(cluster: Cluster, groupId: String) {
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:375:33: error: cannot find 'DispatchWorkItem' in scope
373 |
374 | for (_, broker) in _brokers {
375 | let dispatchBlock = DispatchWorkItem(qos: .unspecified, flags: []) {
| `- error: cannot find 'DispatchWorkItem' in scope
376 |
377 | var handleGetTopicMetadata: ((MetadataResponse) -> Void)!
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:375:56: error: cannot infer contextual base in reference to member 'unspecified'
373 |
374 | for (_, broker) in _brokers {
375 | let dispatchBlock = DispatchWorkItem(qos: .unspecified, flags: []) {
| `- error: cannot infer contextual base in reference to member 'unspecified'
376 |
377 | var handleGetTopicMetadata: ((MetadataResponse) -> Void)!
[18/27] Compiling Franz Cluster.swift
/host/spi-builder-workspace/Sources/Franz/Broker.swift:70:39: error: cannot find type 'DispatchQueue' in scope
68 | private var _readQueues = [Int32: DispatchQueue]()
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
71 | return DispatchQueue(
72 | label: "metadata.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:77:43: error: cannot find type 'DispatchQueue' in scope
75 | }()
76 |
77 | private lazy var _metadataWriteQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
78 | return DispatchQueue(
79 | label: "metadata.write.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:84:39: error: cannot find type 'DispatchQueue' in scope
82 | }()
83 |
84 | private lazy var _adminReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
85 | return DispatchQueue(
86 | label: "admin.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:91:47: error: cannot find type 'DispatchQueue' in scope
89 | }()
90 |
91 | private lazy var _groupCoordinationQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
92 | return DispatchQueue(
93 | label: "group.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:39: error: cannot find 'DispatchQueue' in scope
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot find 'DispatchQueue' in scope
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:32: error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:31: error: cannot call value of non-function type '[AnyHashable : Any]'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot call value of non-function type '[AnyHashable : Any]'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:552:69: error: cannot find type 'DispatchQueue' in scope
550 | }
551 |
552 | private func getReadQueue(_ topic: String, partition: Int32) -> DispatchQueue {
| `- error: cannot find type 'DispatchQueue' in scope
553 | var readQueue: DispatchQueue
554 | if let pq = _readQueues[partition] {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:553:24: error: cannot find type 'DispatchQueue' in scope
551 |
552 | private func getReadQueue(_ topic: String, partition: Int32) -> DispatchQueue {
553 | var readQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
554 | if let pq = _readQueues[partition] {
555 | readQueue = pq
/host/spi-builder-workspace/Sources/Franz/Broker.swift:557:38: error: cannot find 'DispatchQueue' in scope
555 | readQueue = pq
556 | } else {
557 | _readQueues[partition] = DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
558 | label: "\(partition).\(topic).read.stream.franz",
559 | attributes: DispatchQueue.Attributes.concurrent
/host/spi-builder-workspace/Sources/Franz/Broker.swift:559:29: error: cannot find 'DispatchQueue' in scope
557 | _readQueues[partition] = DispatchQueue(
558 | label: "\(partition).\(topic).read.stream.franz",
559 | attributes: DispatchQueue.Attributes.concurrent
| `- error: cannot find 'DispatchQueue' in scope
560 | )
561 | readQueue = _readQueues[partition]!
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:43:29: error: cannot find type 'DispatchQueue' in scope
41 | }
42 |
43 | lazy var dispatchQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
44 | return DispatchQueue(
45 | label: "metadata.cluster.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:334:3: error: cannot find 'DispatchQueue' in scope
332 | public func getConsumer(topics: [TopicName], groupId: String) -> Consumer {
333 | let consumer = Consumer(cluster: self, groupId: groupId)
334 | DispatchQueue(label: "FranzConsumerGetQueue").async {
| `- error: cannot find 'DispatchQueue' in scope
335 | self.joinGroup(id: groupId, topics: topics, callback: { broker, membership in
336 | consumer.broker = broker
/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 | internal init(cluster: Cluster, groupId: String) {
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:375:33: error: cannot find 'DispatchWorkItem' in scope
373 |
374 | for (_, broker) in _brokers {
375 | let dispatchBlock = DispatchWorkItem(qos: .unspecified, flags: []) {
| `- error: cannot find 'DispatchWorkItem' in scope
376 |
377 | var handleGetTopicMetadata: ((MetadataResponse) -> Void)!
/host/spi-builder-workspace/Sources/Franz/Cluster.swift:375:56: error: cannot infer contextual base in reference to member 'unspecified'
373 |
374 | for (_, broker) in _brokers {
375 | let dispatchBlock = DispatchWorkItem(qos: .unspecified, flags: []) {
| `- error: cannot infer contextual base in reference to member 'unspecified'
376 |
377 | var handleGetTopicMetadata: ((MetadataResponse) -> Void)!
[19/27] Compiling Franz Enumerations.swift
/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/Broker.swift:70:39: error: cannot find type 'DispatchQueue' in scope
68 | private var _readQueues = [Int32: DispatchQueue]()
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
71 | return DispatchQueue(
72 | label: "metadata.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:77:43: error: cannot find type 'DispatchQueue' in scope
75 | }()
76 |
77 | private lazy var _metadataWriteQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
78 | return DispatchQueue(
79 | label: "metadata.write.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:84:39: error: cannot find type 'DispatchQueue' in scope
82 | }()
83 |
84 | private lazy var _adminReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
85 | return DispatchQueue(
86 | label: "admin.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:91:47: error: cannot find type 'DispatchQueue' in scope
89 | }()
90 |
91 | private lazy var _groupCoordinationQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
92 | return DispatchQueue(
93 | label: "group.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:39: error: cannot find 'DispatchQueue' in scope
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot find 'DispatchQueue' in scope
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:32: error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:31: error: cannot call value of non-function type '[AnyHashable : Any]'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot call value of non-function type '[AnyHashable : Any]'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
[20/27] Compiling Franz FetchAPI.swift
/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/Broker.swift:70:39: error: cannot find type 'DispatchQueue' in scope
68 | private var _readQueues = [Int32: DispatchQueue]()
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
71 | return DispatchQueue(
72 | label: "metadata.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:77:43: error: cannot find type 'DispatchQueue' in scope
75 | }()
76 |
77 | private lazy var _metadataWriteQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
78 | return DispatchQueue(
79 | label: "metadata.write.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:84:39: error: cannot find type 'DispatchQueue' in scope
82 | }()
83 |
84 | private lazy var _adminReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
85 | return DispatchQueue(
86 | label: "admin.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:91:47: error: cannot find type 'DispatchQueue' in scope
89 | }()
90 |
91 | private lazy var _groupCoordinationQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
92 | return DispatchQueue(
93 | label: "group.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:39: error: cannot find 'DispatchQueue' in scope
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot find 'DispatchQueue' in scope
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:32: error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:31: error: cannot call value of non-function type '[AnyHashable : Any]'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot call value of non-function type '[AnyHashable : Any]'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
[21/27] Compiling Franz Group.swift
/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/Broker.swift:70:39: error: cannot find type 'DispatchQueue' in scope
68 | private var _readQueues = [Int32: DispatchQueue]()
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
71 | return DispatchQueue(
72 | label: "metadata.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:77:43: error: cannot find type 'DispatchQueue' in scope
75 | }()
76 |
77 | private lazy var _metadataWriteQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
78 | return DispatchQueue(
79 | label: "metadata.write.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:84:39: error: cannot find type 'DispatchQueue' in scope
82 | }()
83 |
84 | private lazy var _adminReadQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
85 | return DispatchQueue(
86 | label: "admin.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:91:47: error: cannot find type 'DispatchQueue' in scope
89 | }()
90 |
91 | private lazy var _groupCoordinationQueue: DispatchQueue = {
| `- error: cannot find type 'DispatchQueue' in scope
92 | return DispatchQueue(
93 | label: "group.read.stream.franz",
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:39: error: cannot find 'DispatchQueue' in scope
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot find 'DispatchQueue' in scope
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:32: error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot convert value of type 'Int32.Type' to expected dictionary key type 'AnyHashable'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
/host/spi-builder-workspace/Sources/Franz/Broker.swift:68:31: error: cannot call value of non-function type '[AnyHashable : Any]'
66 | var port: Int32
67 |
68 | private var _readQueues = [Int32: DispatchQueue]()
| `- error: cannot call value of non-function type '[AnyHashable : Any]'
69 |
70 | private lazy var _metadataReadQueue: DispatchQueue = {
[22/27] Compiling Franz GroupCoordinatorAPI.swift
/host/spi-builder-workspace/Sources/Franz/GroupMembershipAPI.swift:411:24: warning: generic parameter 'T' shadows generic parameter from outer scope with the same name; this is an error in the Swift 6 language mode
361 | typealias MemberId = String
362 |
363 | class SyncGroupRequestMessage<T: KafkaMetadata>: KafkaType {
| `- note: 'T' previously declared here
364 |
365 | private var _groupId: String
:
409 |
410 |
411 | class 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
412 |
413 | let memberId: String
[23/27] Compiling Franz GroupMembershipAPI.swift
/host/spi-builder-workspace/Sources/Franz/GroupMembershipAPI.swift:411:24: warning: generic parameter 'T' shadows generic parameter from outer scope with the same name; this is an error in the Swift 6 language mode
361 | typealias MemberId = String
362 |
363 | class SyncGroupRequestMessage<T: KafkaMetadata>: KafkaType {
| `- note: 'T' previously declared here
364 |
365 | private var _groupId: String
:
409 |
410 |
411 | class 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
412 |
413 | let memberId: String
[24/27] Compiling Franz KafkaProtocol.swift
/host/spi-builder-workspace/Sources/Franz/GroupMembershipAPI.swift:411:24: warning: generic parameter 'T' shadows generic parameter from outer scope with the same name; this is an error in the Swift 6 language mode
361 | typealias MemberId = String
362 |
363 | class SyncGroupRequestMessage<T: KafkaMetadata>: KafkaType {
| `- note: 'T' previously declared here
364 |
365 | private var _groupId: String
:
409 |
410 |
411 | class 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
412 |
413 | let memberId: String
[25/27] Compiling Franz Connection.swift
/host/spi-builder-workspace/Sources/Franz/Connection.swift:101:39: error: cannot find type 'CFReadStream' in scope
99 | private var clientId: String
100 |
101 | private var readStream: Unmanaged<CFReadStream>?
| `- error: cannot find type 'CFReadStream' in scope
102 | private var writeStream: Unmanaged<CFWriteStream>?
103 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:102:40: error: cannot find type 'CFWriteStream' in scope
100 |
101 | private var readStream: Unmanaged<CFReadStream>?
102 | private var writeStream: Unmanaged<CFWriteStream>?
| `- error: cannot find type 'CFWriteStream' in scope
103 |
104 | private var inputStream: InputStream?
/host/spi-builder-workspace/Sources/Franz/Connection.swift:112:36: error: cannot find type 'DispatchQueue' in scope
110 | private let responseCorrelationIdSize: Int32 = 4
111 |
112 | private var _inputStreamQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
113 | private var _outputStreamQueue: DispatchQueue
114 | private var _writeRequestBlocks = [()->()]()
/host/spi-builder-workspace/Sources/Franz/Connection.swift:113:37: error: cannot find type 'DispatchQueue' in scope
111 |
112 | private var _inputStreamQueue: DispatchQueue
113 | private var _outputStreamQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
114 | private var _writeRequestBlocks = [()->()]()
115 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:122:29: error: cannot find 'DispatchQueue' in scope
120 | self.port = port
121 |
122 | _inputStreamQueue = DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
123 | label: "\(self.ipv4).\(self.port).input.stream.franz", attributes: []
124 | )
/host/spi-builder-workspace/Sources/Franz/Connection.swift:126:30: error: cannot find 'DispatchQueue' in scope
124 | )
125 |
126 | _outputStreamQueue = DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
127 | label: "\(self.ipv4).\(self.port).output.stream.franz", attributes: []
128 | )
/host/spi-builder-workspace/Sources/Franz/Connection.swift:132:9: error: cannot find 'CFStreamCreatePairWithSocketToHost' in scope
130 | super.init()
131 |
132 | CFStreamCreatePairWithSocketToHost(
| `- error: cannot find 'CFStreamCreatePairWithSocketToHost' in scope
133 | kCFAllocatorDefault,
134 | ipv4 as CFString,
/host/spi-builder-workspace/Sources/Franz/Connection.swift:133:13: error: cannot find 'kCFAllocatorDefault' in scope
131 |
132 | CFStreamCreatePairWithSocketToHost(
133 | kCFAllocatorDefault,
| `- error: cannot find 'kCFAllocatorDefault' in scope
134 | ipv4 as CFString,
135 | UInt32(port),
/host/spi-builder-workspace/Sources/Franz/Connection.swift:134:21: error: cannot find type 'CFString' in scope
132 | CFStreamCreatePairWithSocketToHost(
133 | kCFAllocatorDefault,
134 | ipv4 as CFString,
| `- error: cannot find type 'CFString' in scope
135 | UInt32(port),
136 | &readStream,
/host/spi-builder-workspace/Sources/Franz/Connection.swift:143:3: error: cannot find 'DispatchQueue' in scope
141 | outputStream = writeStream?.takeUnretainedValue()
142 |
143 | DispatchQueue(label: "FranzConnectionQueue").async {
| `- error: cannot find 'DispatchQueue' in scope
144 | self.inputStream?.delegate = self
145 | self.inputStream?.schedule(
/host/spi-builder-workspace/Sources/Franz/Connection.swift:147:14: error: cannot find 'RunLoopMode' in scope
145 | self.inputStream?.schedule(
146 | in: RunLoop.current,
147 | forMode: RunLoopMode.defaultRunLoopMode
| `- error: cannot find 'RunLoopMode' in scope
148 | )
149 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:153:14: error: cannot find 'RunLoopMode' in scope
151 | self.outputStream?.schedule(
152 | in: RunLoop.current,
153 | forMode: RunLoopMode.defaultRunLoopMode
| `- error: cannot find 'RunLoopMode' in scope
154 | )
155 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:225:23: error: cannot find 'DispatchWorkItem' in scope
223 | _requestCallbacks[request.correlationId] = requestCallback
224 | }
225 | let dispatchBlock = DispatchWorkItem(qos: .unspecified, flags: []) {
| `- error: cannot find 'DispatchWorkItem' in scope
226 | //print("\tBeginning Output Stream Write")
227 | if let stream = self.outputStream {
/host/spi-builder-workspace/Sources/Franz/Connection.swift:225:46: error: cannot infer contextual base in reference to member 'unspecified'
223 | _requestCallbacks[request.correlationId] = requestCallback
224 | }
225 | let dispatchBlock = DispatchWorkItem(qos: .unspecified, flags: []) {
| `- error: cannot infer contextual base in reference to member 'unspecified'
226 | //print("\tBeginning Output Stream Write")
227 | if let stream = self.outputStream {
/host/spi-builder-workspace/Sources/Franz/Connection.swift:262:23: warning: result of call to 'read(_:maxLength:)' is unused
260 | var buffer = Array<UInt8>(repeating: 0, count: Int(length))
261 | if activeInputStream.hasBytesAvailable {
262 | activeInputStream.read(&buffer, maxLength: Int(length))
| `- warning: result of call to 'read(_:maxLength:)' is unused
263 | } else {
264 | throw ConnectionError.bytesNoLongerAvailable
/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 | internal init(cluster: Cluster, groupId: String) {
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:39:28: error: cannot find 'DispatchQueue' in scope
37 | }
38 |
39 | private let listenQueue = DispatchQueue(label: "FranzConsumerListenQueue", attributes: .concurrent)
| `- error: cannot find 'DispatchQueue' in scope
40 |
41 | var offsetsToCommit = [TopicName: [PartitionId: (Offset, OffsetMetadata?)]]()
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:39:90: error: cannot infer contextual base in reference to member 'concurrent'
37 | }
38 |
39 | private let listenQueue = DispatchQueue(label: "FranzConsumerListenQueue", attributes: .concurrent)
| `- error: cannot infer contextual base in reference to member 'concurrent'
40 |
41 | var offsetsToCommit = [TopicName: [PartitionId: (Offset, OffsetMetadata?)]]()
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:42:3: error: Objective-C interoperability is disabled
40 |
41 | var offsetsToCommit = [TopicName: [PartitionId: (Offset, OffsetMetadata?)]]()
42 | @objc private func commitGroupoffsets() {
| `- error: Objective-C interoperability is disabled
43 | guard let groupId = self.membership?.group.id, let broker = self.broker else { return }
44 | broker.commitGroupOffset(groupId: groupId, topics: offsetsToCommit, clientId: cluster.clientId)
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:47:3: error: Objective-C interoperability is disabled
45 | }
46 |
47 | @objc private func sendHeartbeat() {
| `- error: Objective-C interoperability is disabled
48 | guard let groupId = self.membership?.group.id,
49 | let generationId = self.membership?.group.generationId,
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:28:10: warning: result of call to 'scheduledTimer(withTimeInterval:repeats:block:)' is unused
26 |
27 | if #available(OSX 10.12, iOS 10, tvOS 10, watchOS 3, *) {
28 | Timer.scheduledTimer(withTimeInterval: 5, repeats: true) { _ in self.commitGroupoffsets() }
| `- warning: result of call to 'scheduledTimer(withTimeInterval:repeats:block:)' is unused
29 | Timer.scheduledTimer(withTimeInterval: 3, repeats: true) { _ in
30 | self.sendHeartbeat()
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:29:10: warning: result of call to 'scheduledTimer(withTimeInterval:repeats:block:)' is unused
27 | if #available(OSX 10.12, iOS 10, tvOS 10, watchOS 3, *) {
28 | Timer.scheduledTimer(withTimeInterval: 5, repeats: true) { _ in self.commitGroupoffsets() }
29 | Timer.scheduledTimer(withTimeInterval: 3, repeats: true) { _ in
| `- warning: result of call to 'scheduledTimer(withTimeInterval:repeats:block:)' is unused
30 | self.sendHeartbeat()
31 | }
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:34:66: error: '#selector' can only be used with the Objective-C runtime
32 | } else {
33 | // Fallback on earlier versions
34 | Timer.scheduledTimer(timeInterval: 5, target: self, selector: #selector(commitGroupoffsets), userInfo: nil, repeats: true)
| `- error: '#selector' can only be used with the Objective-C runtime
35 | Timer.scheduledTimer(timeInterval: 3, target: self, selector: #selector(sendHeartbeat), userInfo: nil, repeats: true)
36 | }
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:35:66: error: '#selector' can only be used with the Objective-C runtime
33 | // Fallback on earlier versions
34 | Timer.scheduledTimer(timeInterval: 5, target: self, selector: #selector(commitGroupoffsets), userInfo: nil, repeats: true)
35 | Timer.scheduledTimer(timeInterval: 3, target: self, selector: #selector(sendHeartbeat), userInfo: nil, repeats: true)
| `- error: '#selector' can only be used with the Objective-C runtime
36 | }
37 | }
/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
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
146 | return Int(crc)
147 | }
[26/27] Compiling Franz Consumer.swift
/host/spi-builder-workspace/Sources/Franz/Connection.swift:101:39: error: cannot find type 'CFReadStream' in scope
99 | private var clientId: String
100 |
101 | private var readStream: Unmanaged<CFReadStream>?
| `- error: cannot find type 'CFReadStream' in scope
102 | private var writeStream: Unmanaged<CFWriteStream>?
103 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:102:40: error: cannot find type 'CFWriteStream' in scope
100 |
101 | private var readStream: Unmanaged<CFReadStream>?
102 | private var writeStream: Unmanaged<CFWriteStream>?
| `- error: cannot find type 'CFWriteStream' in scope
103 |
104 | private var inputStream: InputStream?
/host/spi-builder-workspace/Sources/Franz/Connection.swift:112:36: error: cannot find type 'DispatchQueue' in scope
110 | private let responseCorrelationIdSize: Int32 = 4
111 |
112 | private var _inputStreamQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
113 | private var _outputStreamQueue: DispatchQueue
114 | private var _writeRequestBlocks = [()->()]()
/host/spi-builder-workspace/Sources/Franz/Connection.swift:113:37: error: cannot find type 'DispatchQueue' in scope
111 |
112 | private var _inputStreamQueue: DispatchQueue
113 | private var _outputStreamQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
114 | private var _writeRequestBlocks = [()->()]()
115 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:122:29: error: cannot find 'DispatchQueue' in scope
120 | self.port = port
121 |
122 | _inputStreamQueue = DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
123 | label: "\(self.ipv4).\(self.port).input.stream.franz", attributes: []
124 | )
/host/spi-builder-workspace/Sources/Franz/Connection.swift:126:30: error: cannot find 'DispatchQueue' in scope
124 | )
125 |
126 | _outputStreamQueue = DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
127 | label: "\(self.ipv4).\(self.port).output.stream.franz", attributes: []
128 | )
/host/spi-builder-workspace/Sources/Franz/Connection.swift:132:9: error: cannot find 'CFStreamCreatePairWithSocketToHost' in scope
130 | super.init()
131 |
132 | CFStreamCreatePairWithSocketToHost(
| `- error: cannot find 'CFStreamCreatePairWithSocketToHost' in scope
133 | kCFAllocatorDefault,
134 | ipv4 as CFString,
/host/spi-builder-workspace/Sources/Franz/Connection.swift:133:13: error: cannot find 'kCFAllocatorDefault' in scope
131 |
132 | CFStreamCreatePairWithSocketToHost(
133 | kCFAllocatorDefault,
| `- error: cannot find 'kCFAllocatorDefault' in scope
134 | ipv4 as CFString,
135 | UInt32(port),
/host/spi-builder-workspace/Sources/Franz/Connection.swift:134:21: error: cannot find type 'CFString' in scope
132 | CFStreamCreatePairWithSocketToHost(
133 | kCFAllocatorDefault,
134 | ipv4 as CFString,
| `- error: cannot find type 'CFString' in scope
135 | UInt32(port),
136 | &readStream,
/host/spi-builder-workspace/Sources/Franz/Connection.swift:143:3: error: cannot find 'DispatchQueue' in scope
141 | outputStream = writeStream?.takeUnretainedValue()
142 |
143 | DispatchQueue(label: "FranzConnectionQueue").async {
| `- error: cannot find 'DispatchQueue' in scope
144 | self.inputStream?.delegate = self
145 | self.inputStream?.schedule(
/host/spi-builder-workspace/Sources/Franz/Connection.swift:147:14: error: cannot find 'RunLoopMode' in scope
145 | self.inputStream?.schedule(
146 | in: RunLoop.current,
147 | forMode: RunLoopMode.defaultRunLoopMode
| `- error: cannot find 'RunLoopMode' in scope
148 | )
149 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:153:14: error: cannot find 'RunLoopMode' in scope
151 | self.outputStream?.schedule(
152 | in: RunLoop.current,
153 | forMode: RunLoopMode.defaultRunLoopMode
| `- error: cannot find 'RunLoopMode' in scope
154 | )
155 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:225:23: error: cannot find 'DispatchWorkItem' in scope
223 | _requestCallbacks[request.correlationId] = requestCallback
224 | }
225 | let dispatchBlock = DispatchWorkItem(qos: .unspecified, flags: []) {
| `- error: cannot find 'DispatchWorkItem' in scope
226 | //print("\tBeginning Output Stream Write")
227 | if let stream = self.outputStream {
/host/spi-builder-workspace/Sources/Franz/Connection.swift:225:46: error: cannot infer contextual base in reference to member 'unspecified'
223 | _requestCallbacks[request.correlationId] = requestCallback
224 | }
225 | let dispatchBlock = DispatchWorkItem(qos: .unspecified, flags: []) {
| `- error: cannot infer contextual base in reference to member 'unspecified'
226 | //print("\tBeginning Output Stream Write")
227 | if let stream = self.outputStream {
/host/spi-builder-workspace/Sources/Franz/Connection.swift:262:23: warning: result of call to 'read(_:maxLength:)' is unused
260 | var buffer = Array<UInt8>(repeating: 0, count: Int(length))
261 | if activeInputStream.hasBytesAvailable {
262 | activeInputStream.read(&buffer, maxLength: Int(length))
| `- warning: result of call to 'read(_:maxLength:)' is unused
263 | } else {
264 | throw ConnectionError.bytesNoLongerAvailable
/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 | internal init(cluster: Cluster, groupId: String) {
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:39:28: error: cannot find 'DispatchQueue' in scope
37 | }
38 |
39 | private let listenQueue = DispatchQueue(label: "FranzConsumerListenQueue", attributes: .concurrent)
| `- error: cannot find 'DispatchQueue' in scope
40 |
41 | var offsetsToCommit = [TopicName: [PartitionId: (Offset, OffsetMetadata?)]]()
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:39:90: error: cannot infer contextual base in reference to member 'concurrent'
37 | }
38 |
39 | private let listenQueue = DispatchQueue(label: "FranzConsumerListenQueue", attributes: .concurrent)
| `- error: cannot infer contextual base in reference to member 'concurrent'
40 |
41 | var offsetsToCommit = [TopicName: [PartitionId: (Offset, OffsetMetadata?)]]()
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:42:3: error: Objective-C interoperability is disabled
40 |
41 | var offsetsToCommit = [TopicName: [PartitionId: (Offset, OffsetMetadata?)]]()
42 | @objc private func commitGroupoffsets() {
| `- error: Objective-C interoperability is disabled
43 | guard let groupId = self.membership?.group.id, let broker = self.broker else { return }
44 | broker.commitGroupOffset(groupId: groupId, topics: offsetsToCommit, clientId: cluster.clientId)
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:47:3: error: Objective-C interoperability is disabled
45 | }
46 |
47 | @objc private func sendHeartbeat() {
| `- error: Objective-C interoperability is disabled
48 | guard let groupId = self.membership?.group.id,
49 | let generationId = self.membership?.group.generationId,
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:28:10: warning: result of call to 'scheduledTimer(withTimeInterval:repeats:block:)' is unused
26 |
27 | if #available(OSX 10.12, iOS 10, tvOS 10, watchOS 3, *) {
28 | Timer.scheduledTimer(withTimeInterval: 5, repeats: true) { _ in self.commitGroupoffsets() }
| `- warning: result of call to 'scheduledTimer(withTimeInterval:repeats:block:)' is unused
29 | Timer.scheduledTimer(withTimeInterval: 3, repeats: true) { _ in
30 | self.sendHeartbeat()
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:29:10: warning: result of call to 'scheduledTimer(withTimeInterval:repeats:block:)' is unused
27 | if #available(OSX 10.12, iOS 10, tvOS 10, watchOS 3, *) {
28 | Timer.scheduledTimer(withTimeInterval: 5, repeats: true) { _ in self.commitGroupoffsets() }
29 | Timer.scheduledTimer(withTimeInterval: 3, repeats: true) { _ in
| `- warning: result of call to 'scheduledTimer(withTimeInterval:repeats:block:)' is unused
30 | self.sendHeartbeat()
31 | }
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:34:66: error: '#selector' can only be used with the Objective-C runtime
32 | } else {
33 | // Fallback on earlier versions
34 | Timer.scheduledTimer(timeInterval: 5, target: self, selector: #selector(commitGroupoffsets), userInfo: nil, repeats: true)
| `- error: '#selector' can only be used with the Objective-C runtime
35 | Timer.scheduledTimer(timeInterval: 3, target: self, selector: #selector(sendHeartbeat), userInfo: nil, repeats: true)
36 | }
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:35:66: error: '#selector' can only be used with the Objective-C runtime
33 | // Fallback on earlier versions
34 | Timer.scheduledTimer(timeInterval: 5, target: self, selector: #selector(commitGroupoffsets), userInfo: nil, repeats: true)
35 | Timer.scheduledTimer(timeInterval: 3, target: self, selector: #selector(sendHeartbeat), userInfo: nil, repeats: true)
| `- error: '#selector' can only be used with the Objective-C runtime
36 | }
37 | }
/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
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
146 | return Int(crc)
147 | }
[27/27] Compiling Franz CRC32.swift
/host/spi-builder-workspace/Sources/Franz/Connection.swift:101:39: error: cannot find type 'CFReadStream' in scope
99 | private var clientId: String
100 |
101 | private var readStream: Unmanaged<CFReadStream>?
| `- error: cannot find type 'CFReadStream' in scope
102 | private var writeStream: Unmanaged<CFWriteStream>?
103 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:102:40: error: cannot find type 'CFWriteStream' in scope
100 |
101 | private var readStream: Unmanaged<CFReadStream>?
102 | private var writeStream: Unmanaged<CFWriteStream>?
| `- error: cannot find type 'CFWriteStream' in scope
103 |
104 | private var inputStream: InputStream?
/host/spi-builder-workspace/Sources/Franz/Connection.swift:112:36: error: cannot find type 'DispatchQueue' in scope
110 | private let responseCorrelationIdSize: Int32 = 4
111 |
112 | private var _inputStreamQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
113 | private var _outputStreamQueue: DispatchQueue
114 | private var _writeRequestBlocks = [()->()]()
/host/spi-builder-workspace/Sources/Franz/Connection.swift:113:37: error: cannot find type 'DispatchQueue' in scope
111 |
112 | private var _inputStreamQueue: DispatchQueue
113 | private var _outputStreamQueue: DispatchQueue
| `- error: cannot find type 'DispatchQueue' in scope
114 | private var _writeRequestBlocks = [()->()]()
115 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:122:29: error: cannot find 'DispatchQueue' in scope
120 | self.port = port
121 |
122 | _inputStreamQueue = DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
123 | label: "\(self.ipv4).\(self.port).input.stream.franz", attributes: []
124 | )
/host/spi-builder-workspace/Sources/Franz/Connection.swift:126:30: error: cannot find 'DispatchQueue' in scope
124 | )
125 |
126 | _outputStreamQueue = DispatchQueue(
| `- error: cannot find 'DispatchQueue' in scope
127 | label: "\(self.ipv4).\(self.port).output.stream.franz", attributes: []
128 | )
/host/spi-builder-workspace/Sources/Franz/Connection.swift:132:9: error: cannot find 'CFStreamCreatePairWithSocketToHost' in scope
130 | super.init()
131 |
132 | CFStreamCreatePairWithSocketToHost(
| `- error: cannot find 'CFStreamCreatePairWithSocketToHost' in scope
133 | kCFAllocatorDefault,
134 | ipv4 as CFString,
/host/spi-builder-workspace/Sources/Franz/Connection.swift:133:13: error: cannot find 'kCFAllocatorDefault' in scope
131 |
132 | CFStreamCreatePairWithSocketToHost(
133 | kCFAllocatorDefault,
| `- error: cannot find 'kCFAllocatorDefault' in scope
134 | ipv4 as CFString,
135 | UInt32(port),
/host/spi-builder-workspace/Sources/Franz/Connection.swift:134:21: error: cannot find type 'CFString' in scope
132 | CFStreamCreatePairWithSocketToHost(
133 | kCFAllocatorDefault,
134 | ipv4 as CFString,
| `- error: cannot find type 'CFString' in scope
135 | UInt32(port),
136 | &readStream,
/host/spi-builder-workspace/Sources/Franz/Connection.swift:143:3: error: cannot find 'DispatchQueue' in scope
141 | outputStream = writeStream?.takeUnretainedValue()
142 |
143 | DispatchQueue(label: "FranzConnectionQueue").async {
| `- error: cannot find 'DispatchQueue' in scope
144 | self.inputStream?.delegate = self
145 | self.inputStream?.schedule(
/host/spi-builder-workspace/Sources/Franz/Connection.swift:147:14: error: cannot find 'RunLoopMode' in scope
145 | self.inputStream?.schedule(
146 | in: RunLoop.current,
147 | forMode: RunLoopMode.defaultRunLoopMode
| `- error: cannot find 'RunLoopMode' in scope
148 | )
149 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:153:14: error: cannot find 'RunLoopMode' in scope
151 | self.outputStream?.schedule(
152 | in: RunLoop.current,
153 | forMode: RunLoopMode.defaultRunLoopMode
| `- error: cannot find 'RunLoopMode' in scope
154 | )
155 |
/host/spi-builder-workspace/Sources/Franz/Connection.swift:225:23: error: cannot find 'DispatchWorkItem' in scope
223 | _requestCallbacks[request.correlationId] = requestCallback
224 | }
225 | let dispatchBlock = DispatchWorkItem(qos: .unspecified, flags: []) {
| `- error: cannot find 'DispatchWorkItem' in scope
226 | //print("\tBeginning Output Stream Write")
227 | if let stream = self.outputStream {
/host/spi-builder-workspace/Sources/Franz/Connection.swift:225:46: error: cannot infer contextual base in reference to member 'unspecified'
223 | _requestCallbacks[request.correlationId] = requestCallback
224 | }
225 | let dispatchBlock = DispatchWorkItem(qos: .unspecified, flags: []) {
| `- error: cannot infer contextual base in reference to member 'unspecified'
226 | //print("\tBeginning Output Stream Write")
227 | if let stream = self.outputStream {
/host/spi-builder-workspace/Sources/Franz/Connection.swift:262:23: warning: result of call to 'read(_:maxLength:)' is unused
260 | var buffer = Array<UInt8>(repeating: 0, count: Int(length))
261 | if activeInputStream.hasBytesAvailable {
262 | activeInputStream.read(&buffer, maxLength: Int(length))
| `- warning: result of call to 'read(_:maxLength:)' is unused
263 | } else {
264 | throw ConnectionError.bytesNoLongerAvailable
/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 | internal init(cluster: Cluster, groupId: String) {
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:39:28: error: cannot find 'DispatchQueue' in scope
37 | }
38 |
39 | private let listenQueue = DispatchQueue(label: "FranzConsumerListenQueue", attributes: .concurrent)
| `- error: cannot find 'DispatchQueue' in scope
40 |
41 | var offsetsToCommit = [TopicName: [PartitionId: (Offset, OffsetMetadata?)]]()
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:39:90: error: cannot infer contextual base in reference to member 'concurrent'
37 | }
38 |
39 | private let listenQueue = DispatchQueue(label: "FranzConsumerListenQueue", attributes: .concurrent)
| `- error: cannot infer contextual base in reference to member 'concurrent'
40 |
41 | var offsetsToCommit = [TopicName: [PartitionId: (Offset, OffsetMetadata?)]]()
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:42:3: error: Objective-C interoperability is disabled
40 |
41 | var offsetsToCommit = [TopicName: [PartitionId: (Offset, OffsetMetadata?)]]()
42 | @objc private func commitGroupoffsets() {
| `- error: Objective-C interoperability is disabled
43 | guard let groupId = self.membership?.group.id, let broker = self.broker else { return }
44 | broker.commitGroupOffset(groupId: groupId, topics: offsetsToCommit, clientId: cluster.clientId)
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:47:3: error: Objective-C interoperability is disabled
45 | }
46 |
47 | @objc private func sendHeartbeat() {
| `- error: Objective-C interoperability is disabled
48 | guard let groupId = self.membership?.group.id,
49 | let generationId = self.membership?.group.generationId,
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:28:10: warning: result of call to 'scheduledTimer(withTimeInterval:repeats:block:)' is unused
26 |
27 | if #available(OSX 10.12, iOS 10, tvOS 10, watchOS 3, *) {
28 | Timer.scheduledTimer(withTimeInterval: 5, repeats: true) { _ in self.commitGroupoffsets() }
| `- warning: result of call to 'scheduledTimer(withTimeInterval:repeats:block:)' is unused
29 | Timer.scheduledTimer(withTimeInterval: 3, repeats: true) { _ in
30 | self.sendHeartbeat()
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:29:10: warning: result of call to 'scheduledTimer(withTimeInterval:repeats:block:)' is unused
27 | if #available(OSX 10.12, iOS 10, tvOS 10, watchOS 3, *) {
28 | Timer.scheduledTimer(withTimeInterval: 5, repeats: true) { _ in self.commitGroupoffsets() }
29 | Timer.scheduledTimer(withTimeInterval: 3, repeats: true) { _ in
| `- warning: result of call to 'scheduledTimer(withTimeInterval:repeats:block:)' is unused
30 | self.sendHeartbeat()
31 | }
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:34:66: error: '#selector' can only be used with the Objective-C runtime
32 | } else {
33 | // Fallback on earlier versions
34 | Timer.scheduledTimer(timeInterval: 5, target: self, selector: #selector(commitGroupoffsets), userInfo: nil, repeats: true)
| `- error: '#selector' can only be used with the Objective-C runtime
35 | Timer.scheduledTimer(timeInterval: 3, target: self, selector: #selector(sendHeartbeat), userInfo: nil, repeats: true)
36 | }
/host/spi-builder-workspace/Sources/Franz/Consumer.swift:35:66: error: '#selector' can only be used with the Objective-C runtime
33 | // Fallback on earlier versions
34 | Timer.scheduledTimer(timeInterval: 5, target: self, selector: #selector(commitGroupoffsets), userInfo: nil, repeats: true)
35 | Timer.scheduledTimer(timeInterval: 3, target: self, selector: #selector(sendHeartbeat), userInfo: nil, repeats: true)
| `- error: '#selector' can only be used with the Objective-C runtime
36 | }
37 | }
/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
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
146 | return Int(crc)
147 | }
BUILD FAILURE 6.1 wasm