High-performance NATS client enables messaging support across platforms with features like TCP and WebSocket transport, coroutine-based reactive programming, and a clean API for versatile application deployment.
A fully multiplatform, Ktor-based NATS client in pure Kotlin
NATS.kt is a high-performance NATS client built specifically for Kotlin Multiplatform. Powered by Ktor's networking stack, it brings NATS messaging to every platform Kotlin supports - including servers, mobile apps, browsers and native applications.
Minimum JVM: 17
Minimum Kotlin: 2.2
Gradle:
commonMain.dependencies {
implementation("io.github.n-hass:natskt-platform:0.9.1")
}
import io.natskt.NatsClient
// Simple connection
val client = NatsClient("nats://localhost:4222")
client.connect()
// Advanced configuration
val client = NatsClient {
server = "nats://localhost:4222"
transport = TcpTransport
}
val client = NatsClient {
server = "ws://localhost:4222"
transport = WebSocketTransport.Factory(CIO)
}
// Subscribe to messages
val subscription = client.subscribe("orders.new")
subscription.messages.collect { message ->
println()
}
NATS.kt is under active development.
Legend: ✅ Complete | 🟠 Partially Complete | 🚧 In Progress | ❌ Planned
Check out our examples directory for comprehensive usage examples:
More coming soon!
NATS.kt is released under the Apache 2.0 License.
Ready to build the next generation of distributed Multiplatform applications? Star ⭐ this repo and join our community!
| Platform | Support |
|---|
| JVM | Full |
| Android | Full |
| iOS (ARM64) | Full |
| iOS Simulator (ARM64) | Full |
| macOS (ARM64) | Full |
| Linux (x64) | Full |
| Linux (ARM64) | Full |
| JavaScript (Browser) | Full |
| JavaScript (Node.js) | Full |
| WasmJS | Full |
| Feature | Status | Notes |
|---|
| Core Protocol | ||
| Multiplatform TCP/WebSocket transport | ✅ | |
| Authentication | ✅ | * See security notice below! |
| Publish/Subscribe | ✅ | |
| Request/Reply | ✅ | |
| Jetstream | ||
| Basic API client | ✅ | |
| Pull consumer | ✅ | |
| Push consumer | 🟠 | Functional, missing server liveness timeout |
| Key-Value Store | ✅ | |
| Object Store | ✅ | |
| JetStream Management | ||
| Streams | ✅ | |
| Consumers | ✅ |
Surfaced from shared tags and platforms — no rankings paid for.