kellanburket/franz

Usage

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.

Installation

CocoaPods

Add the following line to your Podfile:

pod "Franz"

Swift Package Manager

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"])
]

Carthage

Add the following dependency to your Cartfile:

github "kellanburket/franz" ~> 1.1.0

Author

Kellan Cummings

Luke Lau

License

Franz is available under the MIT license. See the LICENSE file for more info.

Package Metadata

Repository: kellanburket/franz

Default branch: master

README: README.md