singgel / flink-kafka-hbaseView external linksLinks
【雪球-Infra】功能：实现kafka消息实时落地hbase，支持csv/json字符串两种格式的消息，支持自定义组合rowkey,列簇和列名，支持按照kafka消息流中不同字段join不同的hbase表，并自定义写入列簇和列(join时需评估一下性能)， 支持at least once语义 外部依赖：apollo配置中心，本项目依靠配置驱动，配置存储在apollo配置中心
☆22Dec 5, 2023Updated 2 years ago
Alternatives and similar repositories for flink-kafka-hbase
Users that are interested in flink-kafka-hbase are comparing it to the libraries listed below
Sorting:
- 数据库CDC (Change Data Capture) 核心技术, 持续更新中☆16Apr 30, 2021Updated 4 years ago
- To display modifications to Oracle database contents(DML,DDL) as TEXT FORMAT in the order of Transactions from Online-Redolog or ArchiveL…☆18Apr 2, 2019Updated 6 years ago
- Spark structured-streaming 消费kafka数据写入hbase☆33Jan 22, 2019Updated 7 years ago
- 实时数仓的一些数据处理（mysql、canal、kafka、flink、hbase、kudu等等），以及一堆Flink的练习☆11Jul 1, 2022Updated 3 years ago
- A Scala client for running queries against a Prometheus backend.☆12Dec 23, 2021Updated 4 years ago
- json或SQL语言转为flink或者spark流/批任务☆12Jun 21, 2022Updated 3 years ago
- Oracle XE 11g master-slave (standby replication) on Docker☆10Jul 19, 2017Updated 8 years ago
- ☆15Nov 25, 2020Updated 5 years ago
- A cloud native data mesh implementation☆12Jan 15, 2021Updated 5 years ago
- Store multi-tenant metrics in ClickHouse☆14Aug 26, 2022Updated 3 years ago
- Java library to send structured logs (JSONs) to Logz.io via HTTPS. This the core component of Logzio Appenders in the different logging f…☆13Feb 9, 2026Updated last week
- A workflow orchestration system where the workflow is scheduled as a unit giving resource priority once selected. Priority queuing and c…☆14Nov 16, 2022Updated 3 years ago
- ☆10Apr 13, 2020Updated 5 years ago
- flink实时处理kafka传来的数据通过连接池技术写入hbase☆96Jul 18, 2022Updated 3 years ago
- Illustration of counterfactual inference following Ferenc Huszar example☆13Aug 15, 2025Updated 6 months ago
- 基于flink1.12，使用java，flink sql的demo，包含Mylsql， flinkcdc内置的Mysqlcdc☆12May 27, 2021Updated 4 years ago
- oracle to kafka cdc tools, Synchronize Oracle online redo log to kafka or other big data platforms in realtime☆44Jul 15, 2022Updated 3 years ago
- 蜜蜂牧场是一个数据采集清洗工具，也是一个ETL工具，同时也是一套脚本语言。☆14Jul 1, 2018Updated 7 years ago
- A library enabling DAG structuring of data processing programs such as ETLs☆17Dec 13, 2025Updated 2 months ago
- 大数据学习：各种计算框架：☆11May 20, 2022Updated 3 years ago
- Example using Grafana with Druid☆11Mar 27, 2015Updated 10 years ago
- Java Offline GeoIP maps any IP address to its country code☆12Jan 5, 2020Updated 6 years ago
- A Tool For Identifying The Clues To Online Service Anomalies☆13Nov 13, 2025Updated 3 months ago
- eureka和consul服务注册中心， feign集成restTemplate和ribbon， ribbon负载均衡， hystrix-dashboard熔断器， zuul-filter路由过滤， bus消息总线☆14Oct 9, 2021Updated 4 years ago
- flink学习笔记，包含DataSet、DataStream、Window、缓存、Source、Sink相关说明、水印及示例代码☆12Jul 22, 2023Updated 2 years ago
- Blockchain for Medical Data Access and Permission Management☆13Jan 1, 2023Updated 3 years ago
- ☆15Dec 26, 2017Updated 8 years ago
- SQLAlchemy dialect for Dremio☆16Feb 8, 2023Updated 3 years ago
- Web UI for PrestoDB(https://prestodb.io/)☆14Apr 11, 2019Updated 6 years ago
- Hindsight Administration User Interface☆11Jun 4, 2022Updated 3 years ago
- 一致性hash算法案例☆11Jul 23, 2015Updated 10 years ago
- Fast reactive bridge between Java applications and Yandex.ClickHouse database☆11Apr 9, 2018Updated 7 years ago
- Distributed URL Engine for ClickHouse (public service)☆15Jul 8, 2023Updated 2 years ago
- 23种设计模式的讲解:设计模式分为创建型模式、结构型模式、行为型模式☆13Jul 21, 2018Updated 7 years ago
- 基于C++开发的64卦变换表。☆15May 19, 2025Updated 8 months ago
- Fast, cross-browser automation in node.js☆64May 28, 2014Updated 11 years ago
- ClickHouse Exporter for Prometheus☆11Feb 2, 2019Updated 7 years ago
- Maven overlay for local CAS development and testing☆17Aug 30, 2016Updated 9 years ago
- ☆13Oct 30, 2019Updated 6 years ago