【雪球-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. We may earn a commission when you buy through links labeled 'Ad' on this page.
Sorting:
- 优化flink的多流操作（例如join），优化点不限于数据丢失问题，以及性能问题☆11Apr 8, 2019Updated 7 years ago
- ☆10Apr 13, 2020Updated 6 years ago
- 实时数仓的一些数据处理（mysql、canal、kafka、flink、hbase、kudu等等），以及一堆Flink的练习☆11Jul 1, 2022Updated 3 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 7 years ago
- 大数据学习：各种计算框架：☆11May 20, 2022Updated 3 years ago
- 1-Click AI Models by DigitalOcean Gradient • AdDeploy popular AI models on DigitalOcean Gradient GPU virtual machines with just a single click. Zero configuration with optimized deployments.
- Spark structured-streaming 消费kafka数据写入hbase☆33Jan 22, 2019Updated 7 years ago
- 【易车】- Spark、flink、HBase、Hive、flume集成了一些Hadoop的原生api的一些demo（如HDFS、MapReduce：目前就这两个）；同时测试一些异常功能☆16Apr 4, 2019Updated 7 years ago
- 基于flink1.12，使用java，flink sql的demo，包含Mylsql， flinkcdc内置的Mysqlcdc☆12May 27, 2021Updated 4 years ago
- flink实时处理kafka传来的数据通过连接池技术写入hbase☆95Jul 18, 2022Updated 3 years ago
- 同义词词林扩展版相似度计算-Java☆25Aug 9, 2015Updated 10 years ago
- 使用赌的思想增加mq可靠性。☆23Nov 16, 2022Updated 3 years ago
- my personal blog website created by VueClie, Node and Mongodb☆15Dec 9, 2022Updated 3 years ago
- A simple demo about Flink Upsert-kafka☆16Mar 11, 2021Updated 5 years ago
- apache flink learning☆11Jun 21, 2022Updated 3 years ago
- Managed hosting for WordPress and PHP on Cloudways • AdManaged hosting for WordPress, Magento, Laravel, or PHP apps, on multiple cloud providers. Deploy in minutes on Cloudways by DigitalOcean.
- A Tool For Identifying The Clues To Online Service Anomalies☆13Nov 13, 2025Updated 5 months ago
- 2020年的白皮书，报告等☆20Jan 4, 2021Updated 5 years ago
- Flink Hadoop Compatibility + Elasticsearch for Apache Hadoop = Flink Connector Elasticsearch Source Table。结合flink+hadoop+es 实现的es table s…☆20Jun 28, 2021Updated 4 years ago
- This package contains the grammar in ANTLR g4 format and Java parser for the Data Quality Definition Language (DQDL), used by AWS Glue Da…☆22Mar 26, 2026Updated 3 weeks ago
- 智能数据探索服务(Intelligent Data Exploration Service)，一站式Data + AI数据解决方案！☆35Jul 10, 2023Updated 2 years ago
- A collection of mcp servers/client/sdks☆22Apr 23, 2025Updated 11 months ago
- 通过canal服务监听mysql的binlog增量日志，实现数据异构并实时同步到elasticsearch☆18Oct 28, 2020Updated 5 years ago
- 23种设计模式的讲解:设计模式分为创建型模式、结构型模式、行为型模式☆13Jul 21, 2018Updated 7 years ago
- java版的可以模拟生成任意数据的框架☆21Sep 25, 2018Updated 7 years ago
- GPUs on demand by Runpod - Special Offer Available • AdRun AI, ML, and HPC workloads on powerful cloud GPUs—without limits or wasted spend. Deploy GPUs in under a minute and pay by the second.
- 服务编排☆31Jun 13, 2023Updated 2 years ago
- 自定义Flink的sink或source☆16Sep 5, 2023Updated 2 years ago
- A cloud native data mesh implementation☆12Jan 15, 2021Updated 5 years ago
- ☆14May 19, 2023Updated 2 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…☆13Apr 6, 2026Updated last week
- Spark Streaming + kafka + hbase☆15Nov 19, 2018Updated 7 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
- spark将hdfs数据高性能灌入kafka，然后spark streaming/structured streaming高速消费，关注性能，欢迎提供性能/代码优化建议☆32Mar 24, 2019Updated 7 years ago
- Handling Big Data with Knowledge Graph: A Detailed Guide☆30May 11, 2025Updated 11 months ago
- AI Agents on DigitalOcean Gradient AI Platform • AdBuild production-ready AI agents using customizable tools or access multiple LLMs through a single endpoint. Create custom knowledge bases or connect external data.
- Plugin to push elasticsearch data to newrelic☆44Jul 24, 2013Updated 12 years ago
- flinksql-platform☆19Mar 22, 2021Updated 5 years ago
- Java常用工具类： 包含csv文件操作，excel表POI操作，文件上传，压缩，邮件发送，HTTP请求，XML解析，json操作，密码验证等☆17Sep 12, 2015Updated 10 years ago
- A mock project that makes use of OpenTelemetry Collector, OTLP Exporter, and Receiver. It explains everything about collecting Telemetry …☆10Jul 13, 2020Updated 5 years ago
- SQLAlchemy dialect for Dremio☆16Feb 8, 2023Updated 3 years ago
- layui的阿里文件上传组件模块☆30Apr 12, 2019Updated 7 years ago
- ☆113Sep 25, 2024Updated last year