Discover streamnative/pulsar-flume-ng-sink Open Source project

Stars
20
Rank 1,121,974 (Top 23 %)
Language
Java
License
Apache License 2.0
Created almost 6 years ago
Updated about 2 years ago

streamnative

There are no reviews yet. Be the first to send feedback to the community and the maintainers!

An Apache Flume Sink implementation to publish data to Apache pulsar

kop

Kafka-on-Pulsar - A protocol handler that brings native Kafka protocol to Apache Pulsar

Java

450

pulsar-rs

Rust Client library for Apache Pulsar

Rust

358

pulsar-flink

Elastic data processing with Apache Pulsar and Apache Flink

Java

278

function-mesh

The serverless framework purpose-built for event streaming applications.

210

oxia

Oxia - Metadata store and coordination system

203

mop

MQTT on Pulsar implemented using Pulsar Protocol Handler

Java

170

pulsarctl

a CLI for Apache Pulsar written in Go

152

aop

AMQP on Pulsar protocol handler

Java

114

pulsar-spark

Spark Connector to read and write with Pulsar

Scala

111

tgip-cn

TGIP-CN (Thank God Its Pulsar) is a weekly live video streaming about Apache Pulsar in Chinese.

105

rop

RocketMQ-on-Pulsar - A protocol handler that brings native RocketMQ protocol to Apache Pulsar

Java

apache-pulsar-grafana-dashboard

Apache Pulsar Grafana Dashboard

Jinja

charts

StreamNative Helm Charts Repository: Apache Pulsar, Pulsar Operators, StreamNative Platform, Function Mesh

Smarty

awesome-pulsar

A curated list of Pulsar tools, integrations and resources.

pulsar-beat-output

Elastic Beats Output to Apache Pulsar

examples

Apache Pulsar examples and demos

Java

terraform-provider-pulsar

Terraform provider for managing Apache Pulsar entities

pulsar-resources-operator

pulsar-io-lakehouse

pulsar lakehouse connector

Java

pulsar-io-cloud-storage

Cloud Storage Connector integrates Apache Pulsar with cloud storage.

Java

pulsar-io-kafka

Pulsar IO Kafka Connector

Java

pulsar-user-group-loc-cn

Workspace for China local user group.

pulsar-tracing

Tracing instrumentation for Apache Pulsar clients.

Java

pulsar-hub

The canonical source of StreamNative Hub.

JavaScript

tgip

TGIP (TGI Pulsar) is a weekly live video streaming about Apache Pulsar and its ecosystem.

Shell

oxia-java

A Java client library for Oxia

Java

pulsar-admin-go

The Go library for pulsar admin operations, providing a unified Go API for managing pulsar resources such as tenants, namespaces and topics, etc.

logstash-input-pulsar

Java

sn-platform

StreamNative Platform Downloads

streamnative-academy

Java

logstash-output-pulsar

Logstash output plugin for pulsar

Java

terraform-helm-charts

HCL

pulsar-recipes

A StreamNative library containing a collection of recipes that are implemented on top of the Pulsar client to provide higher-level functionality closer to the application domain.

Java

pulsar_weekly

Pulsar weekly community update

pulumi-controller-runtime

A prototype of a Kubernetes controller based on Pulumi.

flink-example

Flink Pulsar Integration Related Examples

Java

function-mesh-worker-service

Java

pulsar-io-amqp-1-0

support sink/source for AMQP version 1.0.0

Java

pulsar-io-template

It is a project template for developing an Apache Pulsar connector

Java

pulsar-io-aws-lambda

Java

pulsar-delayed-message

Java

pulsar-io-pulsar-connector

Java

terraform-aws-cloud

Terraform modules for provisioning StreamNative Cloud on aws cloud

HCL

pulsar-io-activemq

ActiveMQ Connector integrates Apache Pulsar with Apache ActiveMQ.

Java

pulsar-io-huawei-function-graph-connector

Java

private-cloud

StreamNative Private Cloud is an enterprise product which brings specific controllers for Kubernetes by providing specific Custom Resource Definitions (CRDs).

Shell

pulsar-io-huawei-dis

Pulsar IO connector for huawei DIS https://www.huaweicloud.com/en-us/product/dis.html

Java

homebrew-streamnative

StreamNative Homebrew Formulae

Ruby

pulsar-datadog

Apache Pulsar and Datadog integration.

pulsar-io-sqs

Java

pulsar-flink-patterns

Java

pulsar-io-google-pubsub

Java

psat_exercise_code

pulsar summit asia workshop execise code

Java

terraform-aws-managed-cloud

This repo contains terraform scripts that can be used to provision resources needed for StreamNative Managed Cloud

HCL

community

StreamNative / Apache Pulsar ecosystem community

pulsar-tutorials

Shell

pulsar-io-iotdb

Data sink connector for IoTDB(https://github.com/apache/iotdb)

Java

pulsar-io-bigquery

BigQuery Connector integrates Apache Pulsar with Google BigQuery.

Java

function-mesh-website

Website for https://functionmesh.io/

JavaScript

pulsar-io-http-connector

Java

terraform-managed-cloud

StreamNative Managed Cloud Vendor Access

HCL

pulsar-io-huawei-lts-connector

Java

pulsar-io-snowflakedb

IO Connector for Snowflakedb

Java

sn-demos

Java

terraform-provider-streamnative

Terraform Provider for StreamNative

pulsar-message-filter

pulsar-flink-state-migrate

pulsar flink state migrate tools

Java

skywalking-pulsar-demo

The demo program for Apache SkyWalking and Apache Pulsar integration

Java

kafka-migration

Collection of examples of Kafka apps using KoP

Java

snp-cn

The repo for StreamNative Platform Document Chinese Version.

terraform-google-cloud

Terraform modules for provisioning StreamNative Cloud on google cloud

HCL

pulsar-io-huawei-obs-connector

Java

streamnative/pulsar-flume-ng-sink

streamnative

Reviews

Repository Details

More Repositories