Facilitates MQTT protocol communication, supporting multiple platforms for seamless message exchange and connectivity in distributed systems. Offers a versatile toolset for developing MQTT-based applications.
MQTT 5 for Kotlin Multiplatform, split into:
mktt-core: protocol types, properties, packets, codecsmktt-client: coroutine and Flow based client built on top of mktt-coredependencies {
implementation("io.github.nicolasfara:mktt-core:<version>")
implementation("io.github.nicolasfara:mktt-client:<version>")
}
import io.github.nicolasfara.mktt.client.MqttClient
import io.github.nicolasfara.mktt.client.PublishRequest
io.github.nicolasfara.mktt.core.QoS
io.github.nicolasfara.mktt.core.Topic
io.github.nicolasfara.mktt.core.TopicFilter
kotlinx.coroutines.flow.first
{
client = MqttClient(, ) {
clientId =
}
client.connect()
client.subscribe(listOf(TopicFilter(Topic())))
client.publish(
PublishRequest() {
desiredQoS = QoS.AT_LEAST_ONCE
payload()
},
)
message = client.messages(TopicFilter(Topic())).first()
println(message.payloadAsString())
client.disconnect()
client.close()
}
mktt-core exposes:
kotlinx-iomktt-client exposes:
MqttClientStateFlow<MqttConnectionState>SharedFlow<MqttPublishMessage>mktt-core is covered by deterministic packet/property round-trip tests.mktt-client keeps fast unit tests in commonTest/jvmTest and runs broker-based checks in jvmIntegrationTest.Run unit tests:
./gradlew unitTest
Run integration tests against the local Mosquitto container scaffold (mktt-client/src/jvmIntegrationTest/resources):
MKTT_RUN_INTEGRATION_TESTS=true ./gradlew integrationTest
Optional public broker test (opt-in only):
MKTT_RUN_INTEGRATION_TESTS=true MKTT_RUN_REMOTE_BROKER_TESTS=true ./gradlew integrationTest
messages(filter) local filtering helperconnect, publish, subscribe, unsubscribe, and disconnectSurfaced from shared tags and platforms — no rankings paid for.