numaproj-contrib

All

15 repositories

apache-pulsar-java
Public
Apache Pulsar user-defined source and sink implemented using Java
Java
•
Apache License 2.0
•1•1•0•1•Updated Mar 4, 2025Mar 4, 2025
kafka-java
Public
A Numaflow user-defined source/sink to read/write messages to Kafka topics
numaflow-source numaflow-sink
Java
•
Apache License 2.0
•0•0•9•0•Updated Jan 16, 2025Jan 16, 2025
aws-sqs-source-go
Public
AWS SQS Source for Numaflow implemented in Golang
numaflow-source
Go
•
Apache License 2.0
•3•1•3•0•Updated May 23, 2024May 23, 2024
kafka-source-go
Public
numaflow-source
Go
•
Apache License 2.0
•1•0•3•0•Updated Mar 29, 2024Mar 29, 2024
apache-pulsar-source-go
Public
Apache Pulsar source for Numaflow
numaflow-source
Go
•
Apache License 2.0
•2•1•0•0•Updated Mar 25, 2024Mar 25, 2024
.github
Public
Contrib Repo
0•0•0•0•Updated Mar 24, 2024Mar 24, 2024
nats-source-go
Public
numaflow-source
Go
•
Apache License 2.0
•1•0•1•0•Updated Jan 11, 2024Jan 11, 2024
redisstreams-source-go
Public
User-defined Source for Numaflow for Redis Streams
numaflow-source
Go
•
Apache License 2.0
•1•0•0•0•Updated Jan 11, 2024Jan 11, 2024
gcp-pub-sub-sink-go
Public
numaflow-sink
Go
•1•0•0•0•Updated Jan 9, 2024Jan 9, 2024
apache-pulsar-sink-go
Public
numaflow-sink
Go
•
Apache License 2.0
•1•0•0•0•Updated Jan 8, 2024Jan 8, 2024
gcp-pub-sub-source-go
Public
numaflow-source
Go
•3•0•1•0•Updated Jan 2, 2024Jan 2, 2024
numaflow-utils-go
Public
Utility libraries to help develop Numaflow pipelines
Go
•
Apache License 2.0
•3•1•3•0•Updated Nov 30, 2023Nov 30, 2023
aws-sqs-sink-go
Public
AWS SQS Sink for Numaflow implemented in Golang
numaflow-sink
Go
•
Apache License 2.0
•2•0•2•0•Updated Nov 27, 2023Nov 27, 2023
aws-kinesis-sink-java
Public
0•0•0•0•Updated Sep 1, 2023Sep 1, 2023
aws-kinesis-source-go
Public
0•0•0•0•Updated Sep 1, 2023Sep 1, 2023