A lightweight, binary-based message broker system inspired by Apache Kafka, designed for learning and prototyping. MEGA provides a communication layer protocol for microservices with support for concurrent clients and topic-based message patterns.
- Binary-based protocol for efficient message transmission
- Topic-based produce/consume messaging
- Support for concurrent clients
- Java-based broker with Multiple clients implementation
- Broker: Central message coordinator
- Topics: Message categories
- Producers: Message senders
- Consumers: Message receivers
- ClientHandler: Manages client connections
- Protocol: Binary-based message format
- Java 11 or higher
- Gradle
# Clone the repository
git clone https://github.com/abdel-rahmanSalem/mega.git
cd mega
# Build with Gradle
gradle build
gradle run
The broker will start on port 8080 by default.
This project is under active development. Some features are still being developed.
If you find MEGA useful or interesting, please consider giving it a star on GitHub! Your support helps make the project more visible to others who might benefit from it.
🌟 Star us on GitHub
Follow us on X (Twitter) for updates, tips, and announcements:
Feel free to reach out with questions, suggestions, or just to say hello!