Elastic data processing with Apache Pulsar and Apache Flink

Apache flink

docker部署各类组件示例。已完成组件列表：pulsar, flink，elasticsearch，kafka(single node)

FLaNK AI Weekly covering Apache NiFi, Apache Flink, Apache Kafka, Apache Spark, Apache Iceberg, Apache Ozone, Apache Pulsar, and more...

No description available

Flink Pulsar Integration Related Examples

实时数仓（Flink-Pulsar-Doris）

No description available

An experiment with Flink's Debezium based flink-cdc-connectors DataStream API and Pulsar's Flink connector

An enterprise-level open source unified identity authentication and access control management platform, out-of-the-box, supports WeChat/qq/google/facebook and other SNS and openldap joint authentication, AOP implements API-level multi-factor authentication; among them, the enterprise-level gateway module is enhanced: Supports such as canary request-based response cache filter, canary load balancer, universal signature authentication filter, oidc v1/oauth2.x authentication filter, ip filter, traffic replication filter, quota-based request limiter filter Injector, canary-based fault injector filter, and canary-based humanized log filter; among them, the message bus and real-time analysis modules based on Flink/Kafka/Pulsar/Rabbitmq/HBase/ES/Hive support functions such as abnormal events or Real-time risk warning and early warning, as well as historical event analysis reports, etc.

Self-contained demo using Flink SQL and Apache Pulsar to build a simple analytics pipeline. All you need is Docker! 🐳

No description available

FLiP: StreamNative: Cloud-Native: Streaming Analytics Using Apache Flink SQL on Apache Pulsar

本项目计划打造基于 国产化 平台， 包括 飞腾 和 鲲鹏 CPU平台，麒麟 和 UOS 操作系统的大数据生态组件管理工具以及组件安装包。规划适配Ambari,HDFS,Yarn,ZooKeeper,MapReduce,Hive,Tez,Spark,Pig,Storm,Flink,Sqoop,Flume,Datax,FlinkX,Filebeat,Canal,Debezium,Presto,Druid,ClickHouse,Kylin,TiDB,Greenplum,ElasticSearch,Kafka,pulsar,Oozie,Azkaban ,dolphinscheduler,HBase,Phoenix,Accumulo ,Redis,Ranger,Knox,Atlas,Iceberg,Hudi,DeltaLake,Kudu,Zeppelin,Superset,HUE等组件

Pulsar Hackathon

Using Philter with Kafka, Flink, Pulsar

Apache Pulsar, Python, Raspberry Pi, Gas + Thermal Sensors, Apache Flink, Trino/Presto SQL

How to create a real-time scalable streaming app using Apache NiFi, Apache Pulsar and Apache Flink SQL

An experiment with Flink SQL, Pulsar, and Debezium

FLiP - IoT Examples with Go, Java, MiNiFi, Flink, Pulsar, StreamNative, JSON

A tutorial on how to use pulsar-flink-connector

Streaming Analytics with Apache Pulsar and Apache Flink SQL

Apache Flink - Apache Pulsar - Apache NiFi -> Real-Time Transit Data

Pimoroni Breakout Garden - SGP30 - MLX90650 - RP400 - NiFi - Kafka - Pulsar - Flink - Spark - Iceberg

Docker composified postgres-pulsar-debezium-flink setup

ApacheDeepLearning302 for ApacheCon Global 2021 - Apache Pulsar, Apache MXNet, Apache NiFi, Apache Flink, Apache Tika

FLiP Stack Links - utilizing Apache Pulsar, Apache Flink, Apache NiFi, Apache Spark and Friends. OSS

pulsar flink state migrate tools

Pulsar with Flink SPE

MQTT, Apache Pulsar, Apache Flink, Apache Spark, Pulsar SQL