Skip to content

Releases: conduktor/kafka-connect-websocket

v1.0.0 - Initial Release

17 Dec 01:34
@sderosiaux sderosiaux
v1.0.0
bfdeaa2

Choose a tag to compare

View all tags
v1.0.0 - Initial Release Latest
Latest

Kafka Connect WebSocket Source Connector v1.0.0

This is the initial production-ready release of the Kafka Connect WebSocket Source Connector.

Features

  • Real-time WebSocket streaming into Apache Kafka topics
  • Automatic reconnection with exponential backoff and jitter
  • Authentication support via Bearer tokens and custom headers
  • Subscription messages for exchanges like Binance and Coinbase
  • Sequence-based offset management with session tracking
  • JMX metrics for production monitoring (Prometheus/Grafana)
  • Graceful shutdown with message draining
  • Comprehensive error handling and structured logging

Production Ready

  • Thoroughly tested with 74 unit and integration tests
  • Production-grade error handling and observability
  • Comprehensive documentation
  • SME-reviewed and approved (8.3/10 quality score)

Download

Download the fat JAR below and copy it to your Kafka Connect plugin directory:

# Download the connector
wget https://github.com/conduktor/kafka-connect-websocket/releases/download/v1.0.0/kafka-connect-websocket-1.0.0-jar-with-dependencies.jar

# Copy to plugin directory
cp kafka-connect-websocket-1.0.0-jar-with-dependencies.jar /usr/local/share/kafka/plugins/

# Restart Kafka Connect

Requirements

  • Java 11+
  • Apache Kafka 3.9.0+
  • Kafka Connect 3.9.0+

Documentation

What's Included

This release includes:

  • Production-ready source connector
  • Comprehensive monitoring and metrics
  • Detailed documentation and examples
  • Configuration samples for popular exchanges

Full Changelog: https://github.com/conduktor/kafka-connect-websocket/commits/v1.0.0

Assets 3
Loading