【雪球-Infra】功能:实现kafka消息实时落地hbase,支持csv/json字符串两种格式的消息,支持自定义组合rowkey,列簇和列名,支持按照kafka消息流中不同字段join不同的hbase表,并自定义写入列簇和列(join时需评估一下性能), 支持at least once语义 外部依赖:apollo配置中心,本项目依靠配置驱动,配置存储在apollo配置中心
☆21Dec 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 6 years ago
- ☆10Apr 13, 2020Updated 5 years ago
- eureka和consul服务注册中心, feign集成restTemplate和ribbon, ribbon负载均衡, hystrix-dashboard熔断器, zuul-filter路由过滤, bus消息总线☆14Oct 9, 2021Updated 4 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 6 years ago
- Managed Kubernetes at scale on DigitalOcean • AdDigitalOcean Kubernetes includes the control plane, bandwidth allowance, container registry, automatic updates, and more for free.
- Spark structured-streaming 消费kafka数据写入hbase☆33Jan 22, 2019Updated 7 years ago
- 【易车】- Spark、flink、HBase、Hive、flume集成了一些Hadoop的原生api的一些demo(如HDFS、MapReduce:目前就这两个);同时测试一些异常功能☆16Apr 4, 2019Updated 6 years ago
- flink实时处理kafka传来的数据通过连接池技术写入hbase☆95Jul 18, 2022Updated 3 years ago
- Spark 3.0.0 Structured Streaming Kafka Avro Demo☆15Apr 21, 2023Updated 2 years ago
- ELMO在QA问答,文本分类等NLP上面的应用☆15Apr 13, 2019Updated 6 years ago
- ☆13Oct 30, 2019Updated 6 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
- 干净的RPC全家桶thrift、dubbo、google-protocol-buffer,当然zookeeper注册中心是少不了的,其中在test的测试单元模块,我写了dubbo的底层实现原理(例如socket的RPC反射代理完成跨机器请求,同时还有RMI的代理模型)一看就…☆23Oct 11, 2023Updated 2 years ago
- Wordpress hosting with auto-scaling on Cloudways • AdFully Managed hosting built for WordPress-powered businesses that need reliable, auto-scalable hosting. Cloudways SafeUpdates now available.
- Illustration of counterfactual inference following Ferenc Huszar example☆13Aug 15, 2025Updated 7 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…☆19Jun 28, 2021Updated 4 years ago
- ☆22Nov 4, 2025Updated 4 months ago
- 智能数据探索服务(Intelligent Data Exploration Service),一站式Data + AI数据解决方案!☆35Jul 10, 2023Updated 2 years ago
- 慕课网课程「快速上手Ionic3 多平台开发企业级问答社区」配套源码☆24Mar 6, 2018Updated 8 years ago
- ☆15Dec 26, 2017Updated 8 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
- Simple, predictable pricing with DigitalOcean hosting • AdAlways know what you'll pay with monthly caps and flat pricing. Enterprise-grade infrastructure trusted by 600k+ customers.
- flink学习笔记,包含DataSet、DataStream、Window、缓存、Source、Sink相关说明、水印及示例代码☆12Jul 22, 2023Updated 2 years ago
- 23种设计模式的讲解:设计模式分为创建型模式、结构型模式、行为型模式☆13Jul 21, 2018Updated 7 years ago
- Store multi-tenant metrics in ClickHouse☆14Aug 26, 2022Updated 3 years ago
- java版的可以模拟生成任意数据的框架☆21Sep 25, 2018Updated 7 years ago
- 服务编排☆31Jun 13, 2023Updated 2 years ago
- 基于spark的电商用户行为分析系统☆16Mar 23, 2023Updated 3 years ago
- 《hadoop权威指南》、《大数据架构师指南》、《大数据之路:阿里巴巴大数据实践》《Apache+Kylin权威指南》《MongoDB权威指南》《NOSQL数据库入门》《Lucene实战》《Elasticsearch权威指南》☆254Sep 25, 2025Updated 6 months ago
- 自定义Flink的sink或source☆16Sep 5, 2023Updated 2 years ago
- A cloud native data mesh implementation☆12Jan 15, 2021Updated 5 years ago
- Managed hosting for WordPress and PHP on Cloudways • AdManaged hosting with the flexibility to host WordPress, Magento, Laravel, or PHP apps, on multiple cloud providers. Cloudways by DigitalOcean.
- Java library to send structured logs (JSONs) to Logz.io via HTTPS. This the core component of Logzio Appenders in the different logging f…☆13Mar 9, 2026Updated 3 weeks ago
- 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
- Used Explanatory Data Analysis to identify the root causes for the delay in delivery in the supply chain management☆13Nov 13, 2018Updated 7 years ago
- Handling Big Data with Knowledge Graph: A Detailed Guide☆29May 11, 2025Updated 10 months ago
- Plugin to push elasticsearch data to newrelic☆44Jul 24, 2013Updated 12 years ago