diff --git a/README.md b/README.md index 907dc195..1eaea3b0 100644 --- a/README.md +++ b/README.md @@ -44,7 +44,7 @@ await withThrowingTaskGroup(of: Void.self) { group in // Task receiving acknowledgements group.addTask { - let messageID = try await producer.send( + let messageID = try producer.send( KafkaProducerMessage( topic: "topic-name", value: "Hello, World!" diff --git a/Tests/IntegrationTests/SwiftKafkaTests.swift b/Tests/IntegrationTests/SwiftKafkaTests.swift index e2ca81c8..31cc9b1f 100644 --- a/Tests/IntegrationTests/SwiftKafkaTests.swift +++ b/Tests/IntegrationTests/SwiftKafkaTests.swift @@ -273,7 +273,7 @@ final class SwiftKafkaTests: XCTestCase { var messageIDs = Set() for message in messages { - messageIDs.insert(try await producer.send(message)) + messageIDs.insert(try producer.send(message)) } var acknowledgedMessages = Set()