StreamlineStreamLine - Streaming Analytics
Stars: ✭ 151 (+52.53%)
RegistrySchema Registry
Stars: ✭ 184 (+85.86%)
Azure Event Hubs SparkEnabling Continuous Data Processing with Apache Spark and Azure Event Hubs
Stars: ✭ 140 (+41.41%)
BurrowuiThis is a NodeJS/Angular 2 frontend UI for Kafka cluster monitoring with Burrow
Stars: ✭ 69 (-30.3%)
Kafka Storm StarterCode examples that show to integrate Apache Kafka 0.8+ with Apache Storm 0.9+ and Apache Spark Streaming 1.1+, while using Apache Avro as the data serialization format.
Stars: ✭ 728 (+635.35%)
WirbelsturmWirbelsturm is a Vagrant and Puppet based tool to perform 1-click local and remote deployments, with a focus on big data tech like Kafka.
Stars: ✭ 332 (+235.35%)
Kafka Sprout🚀 Web GUI for Kafka Cluster Management
Stars: ✭ 388 (+291.92%)
Storm Dynamic SpoutA framework for building spouts for Apache Storm and a Kafka based spout for dynamically skipping messages to be processed later.
Stars: ✭ 40 (-59.6%)
Alpakka KafkaAlpakka Kafka connector - Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.
Stars: ✭ 1,295 (+1208.08%)
KarafkaFramework for Apache Kafka based Ruby and Rails applications development.
Stars: ✭ 1,223 (+1135.35%)
Kafka Phpkafka php client
Stars: ✭ 1,340 (+1253.54%)
SyncspoutSyncSpout是用来构造可交互的、同步的Storm拓扑的组件。我们在做实时推荐系统中,希望将Storm的并发性和分布式计算能力应用到“请求-响应”范式中, 比如客户的某次购买行为能够以消息的形式发送到storm拓扑中,storm在指定时间返回推荐结果,也就是说storm需要具有可交互性。基于这样的背景,大数据团队开发了SyncSpout组件, 该组件可以接收客户端异步的消息,经过Storm拓扑异步计算,在指定时间内返回给客户端。
Stars: ✭ 88 (-11.11%)
Poi Android📈 Apache POI for Android
Stars: ✭ 77 (-22.22%)
Fs2 KafkaKafka client for functional streams for scala (fs2)
Stars: ✭ 75 (-24.24%)
Ksql PythonA python wrapper for the KSQL REST API.
Stars: ✭ 98 (-1.01%)
Repository个人学习知识库涉及到数据仓库建模、实时计算、大数据、Java、算法等。
Stars: ✭ 92 (-7.07%)
Kaufmann exKafka backed service library.
Stars: ✭ 86 (-13.13%)
CamusMirror of Linkedin's Camus
Stars: ✭ 81 (-18.18%)
MechaMecha is a free flat-file content management system that carries the concept of minimalism.
Stars: ✭ 88 (-11.11%)
KsppA high performance/ real-time C++ Kafka streams framework (C++17)
Stars: ✭ 80 (-19.19%)
Streamxkafka-connect-s3 : Ingest data from Kafka to Object Stores(s3)
Stars: ✭ 96 (-3.03%)
Community一个仿照牛客网实现的讨论社区,不仅实现了基本的注册,登录,发帖,评论,点赞,回复功能,同时使用前缀树实现敏感词过滤,使用wkhtmltopdf生成长图和pdf,实现网站UV和DAU统计,并将用户头像等信息存于七牛云服务器。
Stars: ✭ 80 (-19.19%)
FilodbDistributed Prometheus time series database
Stars: ✭ 1,286 (+1198.99%)
KafkawizeKafkawize : A Self service Apache Kafka Topic Management tool/portal. A Web application which automates the process of creating and browsing Kafka topics, acls, schemas by introducing roles/authorizations to users of various teams of an org.
Stars: ✭ 79 (-20.2%)
StrawA platform for real-time streaming search
Stars: ✭ 98 (-1.01%)
Php Apache TikaApache Tika bindings for PHP: extract text and metadata from documents, images and other formats
Stars: ✭ 76 (-23.23%)
IcebergApache Iceberg
Stars: ✭ 1,274 (+1186.87%)
RareFast, realtime regex-extraction, and aggregation into common formats such as histograms, numerical summaries, tables, and more!
Stars: ✭ 76 (-23.23%)
Openwhisk CliApache OpenWhisk Command Line Interface (CLI)
Stars: ✭ 73 (-26.26%)
Flow PipelineA set of tools and examples to run a flow-pipeline (sFlow, NetFlow)
Stars: ✭ 86 (-13.13%)
Drain3Drain log template miner in Python3
Stars: ✭ 71 (-28.28%)
Kafka Elasticsearch InjectorGolang app to read records from a set of kafka topics and write them to an elasticsearch cluster
Stars: ✭ 70 (-29.29%)
Docker SupersetRepository for Docker Image of Apache-Superset. [Docker Image: https://hub.docker.com/r/abhioncbr/docker-superset]
Stars: ✭ 86 (-13.13%)
Redirect.rulesQuick and dirty dynamic redirect.rules generator
Stars: ✭ 69 (-30.3%)
TinkerpopApache TinkerPop - a graph computing framework
Stars: ✭ 1,309 (+1222.22%)
TrafficserverApache Traffic Server™ is a fast, scalable and extensible HTTP/1.1 and HTTP/2 compliant caching proxy server.
Stars: ✭ 1,258 (+1170.71%)
Awesome SolrA curated list of Awesome Apache Solr links and resources.
Stars: ✭ 69 (-30.3%)
Bigpipe以Kafka为存储介质,提供异步Http RPC的中间件
Stars: ✭ 84 (-15.15%)
HydraA real-time data replication platform that "unbundles" the receiving, transforming, and transport of data streams.
Stars: ✭ 68 (-31.31%)
LogislandScalable stream processing platform for advanced realtime analytics on top of Kafka and Spark. LogIsland also supports MQTT and Kafka Streams (Flink being in the roadmap). The platform does complex event processing and is suitable for time series analysis. A large set of valuable ready to use processors, data sources and sinks are available.
Stars: ✭ 97 (-2.02%)
MnemonicApache Mnemonic - A non-volatile hybrid memory storage oriented library
Stars: ✭ 91 (-8.08%)
Event Sourcing CastanhaAn Event Sourcing service template with DDD, TDD and SOLID. It has High Cohesion and Loose Coupling, it's a good start for your next Microservice application.
Stars: ✭ 68 (-31.31%)
Fail2ban.webexploitsThis custom Fail2Ban filter and jail will deal with all scans for common Wordpress, Joomla and other Web Exploits being scanned for by automated bots and those seeking to find exploitable web sites.
Stars: ✭ 67 (-32.32%)
Propulsion.NET event stream projection and scheduling platform with EventStore, CosmosDb, Equinox and Kafka integrations
Stars: ✭ 84 (-15.15%)
ThingsboardOpen-source IoT Platform - Device management, data collection, processing and visualization.
Stars: ✭ 10,526 (+10532.32%)