Skip to content

Select theme

English

English
Deutsch
Español
Français
日本語
한국어
Português (BR)
Русский
简体中文

🚀 Get Started
🎭 Build Actors
- Fundamentals
- Typed actors
- Routing
- Patterns
🌐 Distribute
- Cluster
- Distributed Data
  - Overview
  - CRDT types
    Counters
    Registers
    Sets
    Maps
    Designing data
  - Replication
  - Quorum reads/writes
  - Durable storage
- Coordination
- Discovery
  - Overview
  - Seed providers
    Config
    DNS
    Kubernetes API
    Aggregate
  - Receptionist
💾 Persist
- Event sourcing
- Journals
- Snapshot stores
- Replicated event sourcing
- Object storage
- Migration
- FSM
- Delivery
🔌 Integrate
- IO (brokers)
- HTTP
  - Overview
  - Route DSL
  - WebSocket server
  - Marshalling
  - Error handling
  - HTML & XSS
  - Static files
  - Backends
    Fastify
    Express
    Hono
  - Middleware
    Response cache
    Rate limit
    Idempotency key
    CORS
    CSRF
    Security headers
    CSP
    Basic auth
    Bearer token
    IP allowlist
    Request ID
    Timeout
  - Security
- Cache
- Serialization
📊 Observe
- Overview
- Metrics
- Tracing
- Management
- DevTools
✅ Test
⚙️ Operate
- Overview
- Deployment
- Tuning
- Security
- Upgrades
  - Rolling migration
  - Upgrade strategies
- Troubleshooting
- Runtime
💡 Examples
🚚 Migration
📖 Reference
🧰 API Reference
🎁 Extras
- Design decisions
- Architecture Decision Records

Select theme

English

English
Deutsch
Español
Français
日本語
한국어
Português (BR)
Русский
简体中文

On this page

Overview

On this page

Overview

KafkaCommand

KafkaCommand = PublishCommand | SubscribeCommand | CommitCommand | NegativeAcknowledgmentCommand | HeartbeatCommand

Defined in: src/io/broker/KafkaActor.ts:101