Swift 中用于 iOS/macOS 的 Kafka：库、代码示例

在 Swift (iOS/macOS) 中使用 Kafka

Apache Kafka 是一个分布式流数据平台，广泛应用于微服务架构、实时分析和消息交换系统。对于 iOS/macOS 开发者来说，在创建处理实时事件、与 IoT 设备协作或与 Java/Go 后端交互的应用时，可能需要集成 Kafka。在本文中，我们将介绍在 Swift 中使用 Kafka 的主要库、它们的集成方式以及代码示例。

为什么移动/桌面应用需要 Kafka？

尽管 Kafka 通常与服务器端相关联，但在某些场景下，客户端应用会直接与代理交互：

日志记录与分析： 将应用使用事件发送到服务器。
聊天与通知： 通过 Kafka 而非 WebSocket 实时接收消息。
数据同步： 当分布式系统中数据发生变化时更新本地数据。
IoT 与传感器： 通过 Kafka 将设备数据传输到服务器。

Swift 的主要库

目前，有几种成熟的解决方案可用于在 Swift 中使用 Kafka：

SwiftLiteKafka — 基于 librdkafka 的轻量级 C 封装，支持 iOS 和 macOS。
Perfect-Kafka — Perfect 生态系统的一部分，专注于服务器端 Swift (macOS/Linux)，但也可适配客户端。
KafkaSwift — 纯 Swift 实现（无 C 依赖），但性能有限。

最稳定且性能最佳的是 SwiftLiteKafka，因此下文将重点介绍它。

安装 SwiftLiteKafka

该库通过 Swift Package Manager 分发。在 Package.swift 或通过 Xcode 添加依赖：

// Package.swiftdependencies: [    .package(url: "https://github.com/swift-server/swift-lite-kafka.git", from: "1.0.0")]

对于 iOS，还需要启用 C 库 librdkafka 的支持——它会作为依赖自动引入。

基础示例：生产者（发送消息）

创建一个简单的生产者，向主题 "test-topic" 发送字符串：

import SwiftLiteKafka

let config = KafkaConfig()config.bootstrapServers = "localhost:9092"

let producer = try KafkaProducer(config: config)defer { producer.close() }

let message = KafkaMessage(    value: "来自 Swift 的问候！".data(using: .utf8)!,    key: "key1".data(using: .utf8))

try producer.send(message, to: "test-topic")print("消息已发送")

注意：send 是同步调用。对于异步发送，请使用回调或 async/await（Swift 5.5+）。

基础示例：消费者（读取消息）

订阅主题并在循环中读取消息的示例：

import SwiftLiteKafka

let config = KafkaConfig()config.bootstrapServers = "localhost:9092"config.groupId = "swift-consumer-group"

let consumer = try KafkaConsumer(config: config)consumer.subscribe(topics: ["test-topic"])

while true {    let message = try consumer.poll(timeout: .seconds(1))    if let msg = message {        let value = String(data: msg.value, encoding: .utf8) ?? "nil"        print("收到: \\(value)")    }}

对于实际应用，建议使用 async/await 或 Combine，以避免阻塞主线程。