mring33621 / nats-messaging-for-flinkLinks
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
Sorting:
- Golang based remote data frames access (over gRPC or HTTP stream)☆28Updated last week
- Kubernetes operator providing Ray|Spark|Dask|MPI clusters on-demand☆16Updated last year
- Golang SDK for Apache Flink Stateful Functions☆31Updated 4 years ago
- Apache Pulsar Golang Client Library☆10Updated 4 months ago
- Pulsar weekly community update☆10Updated 3 years ago
- Iris-message-processor is a fully distributed Go application meant to replace the sender functionality of Iris and provide reliable, scal…☆29Updated last year
- A multi-master k/v store using gossip for replication written in Go☆19Updated 6 years ago
- Control Plane for Flyte. Flyteadmin is a gRPC + REST Service written in golang and uses a RDBMs to store meta information and management …☆39Updated last year
- go-pulsar is a client library for Pulsar☆22Updated 7 years ago
- Stackable Operator for Apache Kafka☆24Updated this week
- A FUSE module to exposes a Kafka cluster in the filesystem.☆19Updated 11 years ago
- A web app for writing, executing and sharing Benthos pipeline configurations☆49Updated 4 years ago
- Apache arrow examples in golang☆16Updated 4 years ago
- Instrumentation for golang apps☆16Updated 3 months ago
- A Redis Publish/Subscribe NATS Connector☆13Updated 2 years ago
- Go tool for building, distributing and publishing Go projects☆25Updated last week
- Go Client for Hive Metastore☆14Updated 2 years ago
- SenML (Sensor Measurement Lists) format for Go☆13Updated 5 years ago
- A pluggable service to bridge NATS with other technologies☆36Updated 5 years ago
- ☆14Updated last year
- A Spark Publish/Subscribe NATS Connector☆27Updated 4 years ago
- L7mp: A L7 multiprotocol proxy and service mesh☆16Updated 2 years ago
- Fire concurrent HTTP requests, return partial successes after a timeout☆15Updated 2 years ago
- Elegant stream processing pipeline written entirely in Golang☆66Updated 2 years ago
- Tile38 client library for Go☆19Updated 9 months ago
- Cloud Storage Connector integrates Apache Pulsar with cloud storage.☆28Updated last week
- The canonical source of StreamNative Hub.☆17Updated this week
- Go library to work with Parquet Files☆23Updated 3 years ago
- A small project to allow publishing data to Apache Kafka, Apache Pulsar or any other target system☆14Updated 4 years ago
- Prometheus custom collector for JMX metrics of Kafka clients☆12Updated 4 years ago