helper for consuming kubernetes service bindings
Governed message-broker operations CLI for AI agents (Kafka, RabbitMQ, Pulsar, RocketMQ)
OpenTelemetry instrumentation for libraries without official support (BigQuery)
Apache Kafka server destination for walkerOS (kafkajs, JSON serialization, GZIP compression)
Internal wrapper for Apache Kafka
Lightweight event bus for Node.js microservices powered by Redis Streams.
Schema registry connector
Native Apache Kafka client for JavaScript and TypeScript runtimes.
前端链路追踪 SDK,支持浏览器 / UniApp / Vue 插件 / Node.js / npm,与 Go Tracer Kafka 格式兼容
Batch response middleware for the middy framework (SQS, Kinesis, DynamoDB Streams, Kafka, S3 Batch, Firehose)
Event batch parser middleware for the middy framework: Kafka, Kinesis, Firehose, SQS, MQ with pluggable JSON / Avro / Protobuf parsers and AWS Glue Schema Registry support
Per-record handler wrapper for Lambda batch events. Auto-checkpoints under Durable Functions. Pairs with @middy/event-batch-response.
Enhanced Kafka nodes for n8n with manual offset management and timeout handling
Decorator-first NestJS Kafka integration built on Confluent's officially supported @confluentinc/kafka-javascript client
Complete data engineering plugin with Airflow, Kedro, LangGraph, Kafka, dbt, pandas experts, data quality rules, and example scripts for ClaudeAutoPM
kafka-streams for Node.js
Stream processing library for Kafka in Node
Node.js bindings for librdkafka
Intelligent Kafka log analysis with real-time monitoring, anomaly detection, and source code linking
Official StreetJS plugin: Apache Kafka streaming (wraps the dependency-free core Kafka client).
Rdkafka connector