mring33621 / nats-messaging-for-flink
A NATS messaging source for Apache Flink Streaming
☆10Updated 9 years ago
Alternatives and similar repositories for nats-messaging-for-flink:
Users that are interested in nats-messaging-for-flink are comparing it to the libraries listed below
- Apache Pulsar Golang Client Library☆10Updated last month
- Kubernetes operator providing Ray|Spark|Dask|MPI clusters on-demand☆14Updated last year
- Go Client for Hive Metastore☆14Updated 2 years ago
- Pulsar weekly community update☆10Updated 3 years ago
- A web app for writing, executing and sharing Benthos pipeline configurations☆49Updated 3 years ago
- Golang SDK for Apache Flink Stateful Functions☆31Updated 3 years ago
- Golang based remote data frames access (over gRPC or HTTP stream)☆28Updated 2 months ago
- Apache arrow examples in golang☆16Updated 3 years ago
- Lightweight, high performance messaging system for microservices, IoT, and real-time internet connected devices.☆18Updated 4 years ago
- A multi-master k/v store using gossip for replication written in Go☆19Updated 6 years ago
- Cloud Storage Connector integrates Apache Pulsar with cloud storage.☆28Updated 3 weeks ago
- IceDB S3 Proxy to trick S3 clients into only seeing alive files☆12Updated last year
- Communicating with NATS using the HTTP protocol.☆18Updated 10 months ago
- Instrumentation for golang apps☆16Updated last month
- Local syncing package with support for timeouts. This package offers both a sync.Mutex and sync.RWMutex compatible interface.☆18Updated 5 years ago
- A simple UI for Benthos!☆14Updated 2 years ago
- Benchmarking for distributed logs.☆9Updated 8 years ago
- A memcached binary protocol toolkit for go.☆13Updated this week
- A QUIC transport for mangos (scalability protocols) written in pure Go☆24Updated 6 years ago
- grpc over nats.☆28Updated 2 years ago
- Go tool for building, distributing and publishing Go projects☆24Updated last week
- Go library to work with Parquet Files☆23Updated 3 years ago
- Tile38 client library for Go☆19Updated 6 months ago
- A library that implements a family of low-level tools to build persistent messaging systems.☆12Updated 3 years ago
- Nats Java Flink Connector☆20Updated last week
- ☆13Updated last year
- Simple Go 1.8 plugin test for https://jeremywho.com/go-1.8---plugins/☆10Updated 8 years ago
- yet another databus that transfer/transform pipeline data between plugins☆28Updated 7 years ago
- Parallel processing with sequential output, respecting order of input☆10Updated 2 years ago
- Code to support a blog post about optimising some graph stuff☆16Updated 6 years ago