SASL PLAIN support and create topic API
Pre-release
Pre-release
You can now connect to clusters with PLAIN authentication:
let cluster = Cluster(brokers: [("localhost", 9092)],
clientId: "saslClient",
authentication: .plain(username: "franz", password: "password"))
You can also create new topics:
cluster.createTopic(name: "myTopic", partitions: 3, replicationFactor: 2)