Simple usage of kafka to send and receive messages from queue

This Project is a complete package for multi-threaded ETL--It contains code, that can consume messages from distributed Apache Kafka servers parallelly; Secondly, it has easily adaptable Hibernate interface for database operation; Additionally, It is also configured with Spring, to easily access and manage objects across the application, it also…

cap zookeeper

常见设计模式总结、利用设计模式重构、spring的接口实现、redis、zookeeper的使用

graalvm编译zookeeper，提供二进制版本的zookeeper执行文件

Apache Kafka: A distributed event-streaming platform used for building real-time data pipelines and applications. Apache Zookeeper: A centralized service used to maintain configuration information, naming, and synchronization across distributed systems. Kafka relies on Zookeeper for managing cluster metadata.

自定义rpc框架,用于java分布式系统远程调用

基于netty的分布式Rpc框架

ZOOOooooooooooooooooooooMMMMMMMMMMMMMMMMMMMMbbbİİİİİİİİİİİİİİİeeeeeeeeeeeeeeeeeeee

A health check and role assigment implementation using Apache-Curator

梳理 Java 的相关知识，使用 Maven 工具管理

grpcJ使用gRPC实现微服务模块之间RPC通信，提高上下游模块之间流量转发性能，zookeeper作为服务注册发现中心，实现gRPC Server端的注册功能，以及gRPC Client端的服务发现和负载均衡。使用kafka作为消息队列，实现上游模块实时的流量转发到下游模块。基于common-pool2实现了gRPC客户端连接池，提高吞吐量。为了更好的控制上游模块流量转发的速率，使用redis中间件实现限流器

分布式应用系统服务器上下线动态感知程序

init

Lock everything

zookeeper

Sample Project for interacting to Zookeeper (Study Purpose)

Apache Kafka implementation with Spring Boot application. Created 2 microservices that communicate with each other as Producer/Consumer pattern. Event Driven Architecture is followed where messages are published over a Topic Exchange.