Trabajo con Apache Kafka en Swift (iOS/macOS): bibliotecas y ejemplos

Trabajo con Kafka en Swift (iOS/macOS)

Apache Kafka es una plataforma distribuida para transmisión de datos en tiempo real, ampliamente utilizada en arquitectura de microservicios, análisis en tiempo real y sistemas de mensajería. Para desarrolladores de iOS/macOS, la integración de Kafka puede ser necesaria al crear aplicaciones que procesan eventos en tiempo real, trabajan con dispositivos IoT o interactúan con un backend en Java/Go. En este artículo, revisaremos las principales bibliotecas para trabajar con Kafka en Swift, cómo conectarlas y ejemplos de código.

¿Por qué necesitas Kafka en aplicaciones móviles/de escritorio?

Aunque Kafka se asocia más a menudo con el lado del servidor, existen escenarios donde las aplicaciones cliente interactúan directamente con los brokers:

• Registro y análisis: envío de eventos de uso de la aplicación al servidor.
• Chat y notificaciones: recepción de mensajes en tiempo real a través de Kafka en lugar de WebSocket.
• Sincronización de datos: actualización de datos locales cuando hay cambios en un sistema distribuido.
• IoT y sensores: transmisión de datos desde el dispositivo al servidor a través de Kafka.

Principales bibliotecas para Swift

Actualmente, existen varias soluciones maduras para trabajar con Kafka en Swift:

• SwiftLiteKafka — envoltorio ligero en C para librdkafka, compatible con iOS y macOS.
• Perfect-Kafka — parte del ecosistema Perfect, orientada a Swift del lado del servidor (macOS/Linux), pero puede adaptarse para clientes.
• KafkaSwift — implementación pura en Swift (sin dependencias C), pero con rendimiento limitado.

La más estable y eficiente se considera SwiftLiteKafka, por lo que nos centraremos en ella a continuación.

Instalación de SwiftLiteKafka

La biblioteca se distribuye a través de Swift Package Manager. Agrega la dependencia en Package.swift o a través de Xcode:

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

Para iOS, también es necesario habilitar el soporte para la biblioteca C librdkafka — se descarga automáticamente como dependencia.

Ejemplo básico: Producer (envío de mensajes)

Creemos un productor simple que envía una cadena al tópico "test-topic":

import SwiftLiteKafka

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

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

let message = KafkaMessage(    value: "¡Hola desde Swift!".data(using: .utf8)!,    key: "key1".data(using: .utf8))

try producer.send(message, to: "test-topic")print("Mensaje enviado")

Ten en cuenta: send es una llamada síncrona. Para envío asíncrono, usa callbacks o async/await (Swift 5.5+).

Ejemplo básico: Consumer (lectura de mensajes)

Ejemplo de suscripción a un tópico y lectura de mensajes en un bucle:

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("Recibido: \\(value)")    }}

Para aplicaciones reales, se recomienda usar async/await o Combine para no bloquear el hilo principal.

Funcionalidades avanzadas

• SSL/TLS: configuración de cifrado a través de KafkaConfig (propiedades securityProtocol, sslCACertificate