risingwave

RisingWave

RisingWave is a Postgres-compatible SQL database engineered to offer the simplest and most cost-effective approach for processing, analyzing, and managing real-time event streaming data.

This deployment uses PostgreSQL and Minio bundle as Stores. Take a look to Bundled etcd/PostgreSQL/MinIO as Stores for further information

# Install Risingwave
$ helm repo add risingwavelabs https://risingwavelabs.github.io/helm-charts/ --force-update
$ helm repo update
$ kubectl create namespace risingwave

# TLS setup
$ openssl req -x509 -sha256 -nodes -newkey rsa:2048 -days 365 -keyout tls.key -out tls.crt
$ kubectl create secret tls tls-secret-risingwave --cert=tls.crt --key=tls.key
# psql -p 4567 -d dev -U root --set=sslmode=verify-full

$ helm install -n risingwave --create-namespace --set wait=true -f values.yaml <RisingwaveReleaseName> risingwavelabs/risingwave
# $ helm install -n risingwave --create-namespace --set wait=true -f values.yaml risingtest risingwavelabs/risingwave
# helm install -n risingwave --create-namespace --set wait=true --set image.tag=<version_number> <RisingwaveReleaseName> -f values.yaml risingwavelabs/risingwave

$ kubectl port-forward svc/<RisingwaveReleaseName> 4567:svc
# $ kubectl port-forward svc/risingtest 4567:svc

Client connections

# PostgreSQL
$ psql -h localhost -p 4567 -d dev -U root
\d

# Go with dummy data
$ cd cmd
$ go run allInOne.go

Kinesis to Iceberg example

Requirements:

• AWS Kinesis broker. See localstack to deploy a local AWS APIs.
• Iceberg table already created

$ cd cmd
$ go run kinesisToIceberg.go

References

RisingWave

RisingWave configuration

RisingWave examples

Ingest from Kinesis