WedatasphereWeDataSphere is a financial level one-stop open-source suitcase for big data platforms. Currently the source code of Scriptis and Linkis has already been released to the open-source community. WeDataSphere, Big Data Made Easy!
Stars: ✭ 372 (-41.6%)
Kafka exKafka client library for Elixir
Stars: ✭ 469 (-26.37%)
ZenkoZenko is the open source multi-cloud data controller: own and keep control of your data on any cloud.
Stars: ✭ 353 (-44.58%)
FlowggerA fast data collector in Rust
Stars: ✭ 606 (-4.87%)
Kafka KitKafka storage rebalancing, automated replication throttle, cluster API and more
Stars: ✭ 346 (-45.68%)
Springboot Learning基于Gradle构建,使用SpringBoot在各个场景的应用,包括集成消息中间件、前后端分离、数据库、缓存、分布式锁、分布式事务等
Stars: ✭ 340 (-46.62%)
Kafka RustRust client for Apache Kafka
Stars: ✭ 547 (-14.13%)
Kafka PythonPython client for Apache Kafka
Stars: ✭ 4,678 (+634.38%)
DoctorkDoctorK is a service for Kafka cluster auto healing and workload balancing
Stars: ✭ 615 (-3.45%)
DatafakerDatafaker is a large-scale test data and flow test data generation tool. Datafaker fakes data and inserts to varied data sources. 测试数据生成工具
Stars: ✭ 327 (-48.67%)
JockoKafka implemented in Golang with built-in coordination (No ZK dep, single binary install, Cloud Native)
Stars: ✭ 4,445 (+597.8%)
DeferredWork with values that haven't been determined yet.
Stars: ✭ 406 (-36.26%)
Ctpwrapper上海期货交易所CTP接口 Shanghai Future CTP Interface CTP Python API Wrapper
Stars: ✭ 264 (-58.56%)
AkshareAKShare is an elegant and simple financial data interface library for Python, built for human beings! 开源财经数据接口库
Stars: ✭ 4,334 (+580.38%)
God Of Bigdata专注大数据学习面试,大数据成神之路开启。Flink/Spark/Hadoop/Hbase/Hive...
Stars: ✭ 6,008 (+843.17%)
Prelude TsFunctional programming, immutable collections and FP constructs for typescript and javascript
Stars: ✭ 315 (-50.55%)
Jeesuite Libs分布式架构开发套件。包括缓存(一二级缓存、自动缓存管理)、队列、分布式定时任务、文件服务(七牛、阿里云OSS、fastDFS)、日志、搜索、分布式锁、分布式事务、集成dubbo、spring boot支持以及常用的工具包等。
Stars: ✭ 584 (-8.32%)
KsqlThe database purpose-built for stream processing applications.
Stars: ✭ 4,668 (+632.81%)
SurgingSurging is a micro-service engine that provides a lightweight, high-performance, modular RPC request pipeline. The service engine supports http, TCP, WS,Grpc, Thrift,Mqtt, UDP, and DNS protocols. It uses ZooKeeper and Consul as a registry, and integrates it. Hash, random, polling, Fair Polling as a load balancing algorithm, built-in service gove…
Stars: ✭ 3,088 (+384.77%)
SpartaReal Time Analytics and Data Pipelines based on Spark Streaming
Stars: ✭ 513 (-19.47%)
Cookbook🎉🎉🎉JAVA高级架构师技术栈==任何技能通过 “刻意练习” 都可以达到融会贯通的境界,就像烹饪一样,这里有一份JAVA开发技术手册,只需要增加自己练习的次数。🏃🏃🏃
Stars: ✭ 428 (-32.81%)
Rqalpha Mod VnpyRQAlpha 对接 vnpy 的扩展 Mod。通过启用该 Mod 来实现期货策略的实盘交易
Stars: ✭ 285 (-55.26%)
FreestyleA cohesive & pragmatic framework of FP centric Scala libraries
Stars: ✭ 627 (-1.57%)
Real Time Stock Market PredictionIn this repository, I have developed the entire server-side principal architecture for real-time stock market prediction with Machine Learning. I have used Tensorflow.js for constructing ml model architecture, and Kafka for real-time data streaming and pipelining.
Stars: ✭ 414 (-35.01%)
Python3 Concurrency Pics 02爬取 www.mzitu.com 全站图片,截至目前共5162个图集,16.5万多张美女图片,使用 asyncio 和 aiohttp 实现的异步版本只需要不到2小时就能爬取完成。按日期创建图集目录,保存更合理。控制台只显示下载的进度条,详细信息保存在日志文件中。支持异常处理,不会终止爬虫程序。失败的请求,下次再执行爬虫程序时会自动下载
Stars: ✭ 275 (-56.83%)
Gohangoutgolang版本的hangout, 希望能省些内存. 使用了自己写的Kafka lib .. 虚. 不过我们在生产环境已经使用近1年, kafka 版本从0.9.0.1到2.0都在使用, 目前情况稳定. 吞吐量在每天2000亿条以上.
Stars: ✭ 507 (-20.41%)
KminionKMinion is a feature-rich Prometheus exporter for Apache Kafka written in Go. It is lightweight and highly configurable so that it will meet your requirements.
Stars: ✭ 274 (-56.99%)
CppkafkaModern C++ Apache Kafka client library (wrapper for librdkafka)
Stars: ✭ 413 (-35.16%)
QbusbridgeThe Apache Kafka Client SDK
Stars: ✭ 272 (-57.3%)
Java Studyjava-study 是本人学习Java过程中记录的一些代码!从Java基础的数据类型、jdk1.8的Lambda、Stream和日期的使用、 IO流、数据集合、多线程使用、并发编程、23种设计模式示例代码、常用的工具类, 以及一些常用框架,netty、mina、springboot、kafka、storm、zookeeper、redis、elasticsearch、hbase、hive等等。
Stars: ✭ 571 (-10.36%)
Gpmall【咕泡学院实战项目】-基于SpringBoot+Dubbo构建的电商平台-微服务架构、商城、电商、微服务、高并发、kafka、Elasticsearch
Stars: ✭ 4,241 (+565.78%)
Kafkastreams CepComplex Event Processing on top of Kafka Streams
Stars: ✭ 257 (-59.65%)
Kafka Streamsequivalent to kafka-streams 🐙 for nodejs ✨🐢🚀✨
Stars: ✭ 613 (-3.77%)
LibrdkafkaThe Apache Kafka C/C++ library
Stars: ✭ 5,617 (+781.79%)
CapDistributed transaction solution in micro-service base on eventually consistency, also an eventbus with Outbox pattern
Stars: ✭ 5,208 (+717.58%)
JackdawA Clojure library for the Apache Kafka distributed streaming platform.
Stars: ✭ 257 (-59.65%)
async-oneshotA fast, small, full-featured, no-std compatible oneshot channel
Stars: ✭ 55 (-91.37%)
BrodApache Kafka client library for Erlang/Elixir
Stars: ✭ 501 (-21.35%)
GnomockTest your code without writing mocks with ephemeral Docker containers 📦 Setup popular services with just a couple lines of code ⏱️ No bash, no yaml, only code 💻
Stars: ✭ 398 (-37.52%)
kafka-0.11-examplesCode snippets that demonstrate how to leverage the new Kafka 0.11 APIs
Stars: ✭ 17 (-97.33%)
parallel-dfs-dagA parallel implementation of DFS for Directed Acyclic Graphs (https://research.nvidia.com/publication/parallel-depth-first-search-directed-acyclic-graphs)
Stars: ✭ 29 (-95.45%)
OckamEnd-to-end encrypted messaging and mutual authentication between cloud and edge-device applications
Stars: ✭ 395 (-37.99%)
trader交易模块
Stars: ✭ 20 (-96.86%)