Kafka Vehicle Tutorial
Transform Kafka messages into dynamic, stateful, real-time streaming endpoints
Backend
Get Started
Step by step instructions to get started building streaming data application backends.
Confluent Cloud Tutorial
Integrate seamlessly with enterprise datasets
Core Concepts
Key ideas necessary to understanding stateful service and streaming API development with the Nstream Toolkit.
Toolkit Overview
What is the Nstream Toolkit?
Toolkit Agent Design
Compose agents using the NStream Toolkit patch system
Toolkit Lane Design
Organize lanes using the Nstream Toolkit
Ingress Bridges
Ingest from various data sources using Nstream Toolkit ingress connectors.
Overview
Ingress Bridge Fundamentals
Confluent Ingress
Low-code Confluent-sourced data ingestion
Kafka Ingress
Low-code Kafka-sourced data ingestion
Pulsar Ingress
Low-code Pulsar-sourced data ingestion
NATS Ingress
Low-code NATS-sourced data ingestion
MongoDB Ingress
Low-code MongoDB-sourced data ingestion
Druid Ingress
Low-code Druid-sourced data ingestion
JDBC Ingress
Low-code JDBC-sourced data ingestion
Redis Ingress
Low-code Redis-sourced data ingestion
DynamoDB Ingress
Low-code DynamoDB-sourced data ingestion
RabbitMQ Ingress
Low-code RabbitMQ-sourced data ingestion
JMS Ingress
Low-code JMS-sourced data ingestion
HTTP Ingress
Low-code HTTP-sourced data ingestion
Avro Handling
Low-code Avro Data Ingestion
Relay DSL
Low-code Ingested Message Routing
Egress Bridges
Egress to various data sinks using Nstream Toolkit egress connectors.
Confluent Egress
Low-code data population into Confluent Cloud
Kafka Egress
Low-code Kafka publishing
Pulsar Egress
Low-code Pulsar data sink
NATS Egress
Low-code NATS data sink
MongoDB Egress
Low-code MongoDB data sink
Druid Egress
Low-code Druid data sink
JDBC Egress
Low-code JDBC data sink
Redis Egress
Low-code Redis data sink
DynamoDB Egress
Low-code DynamoDB data sink
RabbitMQ Egress
Low-code RabbitMQ data sink
JMS Egress
Low-code JMS data sink
Patches
Add configuration driven functionality to Swim applications using Nstream Toolkit patches.
Agent Relationship
Group agents using the Nstream toolkit
History Patch
Add a time series history lane to agents
Summary Stats Patch
Calculate rolling statistics from events
Geopoint Patch
Geopoint agents using the Nstream toolkit
REST API Support
Externally view the instanteneous state of a Web Agent using a REST API
Persistence
Persistence Overview
Nstream Persistence Overview
Key-Value Adapter
Key-Value Store Adapter
RocksDb
RocksDb Store Implementation
Cassandra
Cassandra Store Implementation
Ignite
Ignite Store Implementation
Nstream is licensed under the Redis Source Available License 2.0 (RSALv2).