Repository Index

RxJava – Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM.

• java
• rxjava
• flow
• reactive-streams

A libre lightweight streaming front-end for Android.

• youtube-video
• video
• newpipe
• watch

Apache Kafka - A distributed event streaming platform

• scala
• kafka
• java
• streaming

Apache RocketMQ is a cloud native messaging and streaming platform, making it simple to build event-driven applications.

• rocketmq
• cloud-native
• eventing
• java

QuestDB is a high performance, open-source, time-series database

• time-series
• low-latency
• database
• sql

Modern Java - A Guide to Java 8

• java-8
• tutorial
• lambda-expressions
• java

Apache Pulsar - distributed pub-sub messaging system

• pulsar
• pubsub
• messaging
• streaming

Translatedflink learning blog. http://www.54tianzhisheng.cn/ Covers Flink introduction, concepts, principles, hands-on practice, performance tuning, source code analysis, and more. Includes learning examples involving Flink Connector, Metrics, Library, DataStream API, Table API & SQL, and also shares large-scale project cases of Flink in production (PV/UV, log storage, real-time deduplication of 10 billion records, monitoring and alerting). You are welcome to support my column 《大数据实时计算引擎 Flink 实战与性能优化》 ("Big Data Real-Time Computing Engine Flink: Hands-On Practice and Performance Optimization")

• flink
• kafka
• elasticsearch
• spark

Logstash - transport and process your logs, events, or other data

• etl-framework
• streaming
• logging
• java

Change data capture for a variety of databases. Please log issues at https://github.com/debezium/dbz/issues.

• change-data-capture
• kafka-connect
• apache-kafka
• debezium

Open-Source Web UI for Apache Kafka Management

• kafka-ui
• kafka-brokers
• kafka
• kafka-streams

业内为数不多致力于极致体验的超强全自研跨平台(windows/linux/android/iOS)流媒体内核，通过模块化自由组合，支持实时RTMP推流、RTSP推流、RTMP播放器、RTSP播放器、录像、多路流媒体转发、音视频导播、动态视频合成、音频混音、直播互动、内置轻量级RTSP服务等，比快更快，业界真正靠谱的超低延迟直播SDK(延迟低至100~200ms)。

• rtmp-pusher
• rtmp-player
• android-rtmp
• ios-rtmp

SeaTunnel is a multimodal, high-performance, distributed, massive data integration tool.

• data-integration
• high-performance
• offline
• real-time

Efficient reliable UDP unicast, UDP multicast, and IPC message transport

• messaging
• java
• c-plus-plus
• ipc

Apache Beam is a unified programming model for Batch and Streaming data processing.

• python
• java
• big-data
• beam

Apache Storm

• storm
• apache
• distributed
• streaming

Hazelcast is a unified real-time data platform combining stream processing with a fast data store, allowing customers to act instantly on data-in-motion for real-time insights.

• java
• hazelcast
• in-memory
• big-data

Upserts, Deletes And Incremental Processing on Big Data.

• hudi
• apachehudi
• datalake
• bigdata

Your go-to microservice framework for any situation, from the creator of Netty et al. You can build any type of microservice leveraging your favorite technologies, including gRPC, Thrift, Kotlin, Retrofit, Reactive Streams, Spring Boot and Dropwizard.

• http
• http2
• http-server
• http-client

Reactive Streams Specification for the JVM

XChange is a Java library providing a streamlined API for interacting with 60+ Bitcoin and Altcoin exchanges providing a consistent interface for trading and accessing market data.

• bitcoin

JeroMQ is a pure Java implementation of the ZeroMQ messaging library, offering high-performance asynchronous messaging for distributed or concurrent applications.

• jeromq
• libzmq
• messaging
• networking

The goal of this project is to allow integrated or USB-connected webcams to be accessed directly from Java. Using provided libraries users are able to read camera images and detect motion. Main project consist of several sub projects - the root one, which contains required classes, build-in webcam driver compatible with Windows, Linux and Mac OS, which can stream images as fast as your camera can serve them (up to 50 FPS). Main project can be used standalone, but user is able to replace build-in driver with different one - such as OpenIMAJ, GStreamer, V4L4j, JMF, LTI-CIVIL, FMJ, etc.

• webcam
• java
• webcam-capture

Enhancing Java Stream API

• java
• java8
• collections
• streams-api