Franz is an Apache Kafka 0.9.0 client for iOS and macOS.
import Franz
let cluster = Cluster(brokers: [("localhost", 9092)], clientId: "FranzExample")
let consumer = cluster.getConsumer(topics: ["test"], groupId: "group")
consumer.listen { message in
print(String(data: message.value, encoding: .utf8)!)
}
cluster.sendMessage("test", message: "Hello world!")
You can view the documentation here.
The current release of Franz should be considered beta. It is not necessarily ready for production code.
The repo has example projects for CocoaPods and Swift Package Manager.
Add the following line to your Podfile:
pod "Franz"
Add the following dependency to your Package.swift:
dependencies: [
.package(url: "https://github.com/kellanburket/franz.git", from: "1.1.0"),
],
targets: [
.target(name: "MyTarget", dependencies: ["Franz"])
]
Add the following dependency to your Cartfile:
github "kellanburket/franz" ~> 1.1.0
Kellan Cummings
Luke Lau
Franz is available under the MIT license. See the LICENSE file for more info.