datastax/pulsar-sink

Stars
14
Rank 1,438,076 (Top 29 %)
Language
Java
License
Apache License 2.0
Created almost 4 years ago
Updated about 2 months ago

datastax/pulsar-sink

datastax

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

An Apache Pulsar® sink for transferring events/messages from Pulsar topics to Apache Cassandra®, DataStax Astra or DataStax Enterprise (DSE) tables.

spark-cassandra-connector

DataStax Connector for Apache Spark to Apache Cassandra

python-driver

DataStax Python Driver for Apache Cassandra

nodejs-driver

DataStax Node.js Driver for Apache Cassandra

csharp-driver

DataStax C# Driver for Apache Cassandra

php-driver

[MAINTENANCE ONLY] DataStax PHP Driver for Apache Cassandra

cpp-driver

DataStax C/C++ Driver for Apache Cassandra

cass-operator

The DataStax Kubernetes Operator for Apache Cassandra

ruby-driver

[MAINTENANCE ONLY] DataStax Ruby Driver for Apache Cassandra

graph-book

The Code Examples and Notebooks for The Practitioners Guide to Graph Data

cql-proxy

A client-side CQL proxy/sidecar.

astra-assistants-api

Drop in replacement for the OpenAI Assistants API

ragstack-ai

RAGStack is an out of the box solution simplifying Retrieval Augmented Generation (RAG) in AI apps.

metric-collector-for-apache-cassandra

Drop-in metrics collection and dashboards for Apache Cassandra

dsbulk

DataStax Bulk Loader (DSBulk) is an open-source, Apache-licensed, unified tool for loading into and unloading from Apache Cassandra(R), DataStax Astra and DataStax Enterprise (DSE)

zdm-proxy

An open-source component designed to seamlessly handle the real-time client application activity while a migration is in progress.

docker-images

Docker images published by DataStax.

dynamo-cassandra-proxy

Preview version of an open source tool that enables developers to run their AWS DynamoDB™ workloads on Apache Cassandra™. With the proxy, developers can run DynamoDB workloads outside of AWS (including on premises, other clouds, and in hybrid configurations).

cstar_perf

Apache Cassandra performance testing platform

ai-chatbot-starter

A starter app to build AI powered chat bots with Astra DB and LlamaIndex

zdm-proxy-automation

An Ansible-based automation suite to deploy and manage the Zero Downtime Migration Proxy

ragbot-starter

An Astra DB and OpenAI chatbot

wikichat

graph-examples

fallout

Distributed System Testing as a Service

pulsar-jms

DataStax Starlight for JMS, a JMS API for Apache Pulsar ®

reactive-pulsar

Reactive Streams adapter for Apache Pulsar Java Client

pulsar-helm-chart

Apache Pulsar Helm chart

SwiftieGPT

kafka-examples

Examples of using the DataStax Apache Kafka Connector.

kaap

KAAP, Kubernetes Autoscaling for Apache Pulsar

cassandra-quarkus

An Apache Cassandra(R) extension for Quarkus

cdc-apache-cassandra

Datastax CDC for Apache Cassandra

pulsar-admin-console

Pulsar Admin Console is a web based UI that administrates topics, namespaces, sources, sinks and various aspects of Apache Pulsar features.

sstable-to-arrow

simulacron

Simulacron - An Apache Cassandra® Native Protocol Server Simulator

astra-cli

Command Line Interface for DataStax Astra

code-samples

Code samples from DataStax

starlight-for-rabbitmq

Starlight for RabbitMQ, a proxy layer between RabbitMQ/AMQP0.9.1 clients and Apache Pulsar

dse-metric-reporter-dashboards

Prometheus & Grafana dashboards for DSE metric collector

diagnostic-collection

Diagnostic Collector for Apache Cassandra

cassandra-data-migrator

Cassandra Data Migrator - Migrate & Validate data between origin and target Apache Cassandra®-compatible clusters.

spark-cassandra-stress

A tool for testing the DataStax Spark Connector against Apache Cassandra or DSE

cla-enforcer

A Contributor License Agreement enforcement bot

pulsar-heartbeat

Pulsar Heartbeat monitors Pulsar cluster availability, tracks latency of Pulsar message pubsub, and reports failures of the Pulsar cluster. It produces synthetic workloads to measure end-to-end message pubsub latency.

astrapy

AstraPy is a Pythonic interface for DataStax Astra DB and the Data API

cassandra-data-apis

Data APIs for Apache Cassandra

cassandra-log4j-appender

Cassandra appenders for Log4j

terraform-provider-astra

A project that allows DataStax Astra users to manage their full database lifecycle for Astra Serverless databases (built on Apache Cassandra(TM)) using Terraform

labs

DataStax Labs preview program

starlight-for-kafka

DataStax - Starlight for Kafka

dc-failover-demo

Fault Tolerant Applications with Apache Cassandra™ Demo

astra-sdk-java

Set of client side libraries to help with Astra Platform usage

movies_plus_plus

kafka-sink

Apache Kafka® sink for transferring events/messages from Kafka topics to Apache Cassandra®, DataStax Astra and DataStax Enterprise (DSE).

astrajs

A monorepo containing tools for interacting with DataStax Astra and Stargate

astra-db-ts

Typescript client for Astra DB Vector

native-protocol

An implementation of the Apache Cassandra® native protocol

block-explorer

go-cassandra-native-protocol

Cassandra Native Protocol bindings for the Go language

cassandra-reactive-demo

A demo application that interacts with Apache Cassandra(R) using the Java driver 4.4+ and reactive programming

adelphi

Automation tool for testing C* OSS that assembles cassandra-diff, nosqlbench, fqltool

pulsar-transformations

astra-db-java

Java Client for DataStax Astra DB and the Data API

dsbulk-migrator

release-notes

Release Notes for DataStax Products

gatling-dse-plugin

gocql-astra

Support for gocql on Astra

snowflake-connector

Datastax Snowflake Sink Connector for Apache Pulsar

vault-plugin-secrets-datastax-astra

HashiCorp Vault Plugin for Datstax Astra

pulsar-3rdparty-connector

This project provides simple templates and instructions to build Apache Pulsar connectors on base of the existing Apache Kafka connectors.

astra-client-go

dsbench-labs

DSBench - A Database Testing Power Tool

remote-junit-runner

JUnit runner that executes tests in a remote JVM

cass-config-builder

Configuration builder for Apache Cassandra based on definitions at datastax/cass-config-definitions

astra-db-chatbot-starter

java-driver-scala-extras

Scala extensions and utilities for the DataStax Java Driver

burnell

A proxy to Pulsar cluster

ai-agent-java

AI Agent Starter in Java

gatling-dse-stress

gatling-dse-simcatalog

ds-support-diagnostic-collection

Scripts for collection of diagnostic information from DSE/Cassandra clusters running on various platforms

java-quotient-filter

A Java Quotient Filter implementation.

charts

DataStax Helm Charts

pulsar-ansible

ragstack-ai-ts

astra-ide-plugin

terraform-helm-oci-release

cass-config-definitions

go-cassandra-simple-client

A simple Go client for the Cassandra native protocol

doyouknowyourstuff

terraform-datastax-ai-stack

astra-db-recommendations-starter

java-driver-examples-osgi

Examples showing the usage of the DataStax Java driver in OSGi applications.

nodejs-driver-graph

DataStax Node.js Driver Extensions for DSE Graph

aws-secrets-manager-integration-astra

starlight-for-grpc

homebrew-luna-streaming-shell

astra-block-examples

Various Astra Block Examples

cassandra-drivers-smoke-test

Smoke tests for Apache Cassandra using the DataStax Drivers

junitpytest

JUnit5 plugin to run pytest via Gradle