Kafka в Swift для iOS/macOS: библиотеки, примеры кода |…

Работа с Kafka в Swift (iOS/macOS)

Apache Kafka — это распределенная платформа для потоковой передачи данных, широко используемая в микросервисной архитектуре, аналитике реального времени и системах обмена сообщениями. Для разработчиков под iOS/macOS интеграция Kafka может потребоваться при создании приложений, которые обрабатывают события в реальном времени, работают с IoT-устройствами или взаимодействуют с бэкендом на Java/Go. В этой статье мы рассмотрим основные библиотеки для работы с Kafka в Swift, способы их подключения и примеры кода.

Зачем нужен Kafka в мобильных/десктопных приложениях?

Хотя Kafka чаще ассоциируется с серверной стороной, существуют сценарии, когда клиентские приложения напрямую взаимодействуют с брокерами:

Логирование и аналитика: отправка событий использования приложения на сервер.
Чат и уведомления: получение сообщений в реальном времени через Kafka вместо WebSocket.
Синхронизация данных: обновление локальных данных при изменениях в распределенной системе.
IoT и датчики: передача данных с устройства на сервер через Kafka.

Основные библиотеки для Swift

На данный момент существует несколько зрелых решений для работы с Kafka в Swift:

SwiftLiteKafka — легковесная обертка на C для librdkafka, поддерживает iOS и macOS.
Perfect-Kafka — часть экосистемы Perfect, ориентирована на серверный Swift (macOS/Linux), но может быть адаптирована для клиентов.
KafkaSwift — чистая реализация на Swift (без C-зависимостей), но с ограниченной производительностью.

Наиболее стабильной и производительной считается SwiftLiteKafka, поэтому далее будем рассматривать её.

Установка SwiftLiteKafka

Библиотека распространяется через Swift Package Manager. Добавьте зависимость в Package.swift или через Xcode:

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

Для iOS необходимо также включить поддержку C-библиотеки librdkafka — она автоматически подтягивается как зависимость.

Базовый пример: Producer (отправка сообщений)

Создадим простой продюсер, который отправляет строку в топик "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+).

Базовый пример: Consumer (чтение сообщений)

Пример подписки на топик и чтения сообщений в цикле:

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, чтобы не блокировать главный поток.

Продвинутые возможности

SSL/TLS: настройка шифрования через KafkaConfig (свойства securityProtocol, sslCACertificate).
Сериализация: используйте Codable для отправки/получения JSON, Protobuf или Avro.
Партиционирование: ручное указание ключа или партиции для балансировки нагрузки.
Транзакции: поддержка exactly-once семантики (требуется Kafka 0.11+).