implementation of partitioning mechanism on Apache Kafka and asynchronous communication between Vert.x microservices
-
Updated
Oct 17, 2024 - Java
implementation of partitioning mechanism on Apache Kafka and asynchronous communication between Vert.x microservices
Xinfra Monitor monitors the availability of Kafka clusters by producing synthetic workloads using end-to-end pipelines to obtain derived vital statistics - E2E latency, service produce/consume availability, offsets commit availability & latency, message loss rate and more.
Kafka Training Examples
Kafka Zookeeper RESTful API to perform topic/consumer group administration/metric(offset\lag\message) collection and monitor
This project contains API's where Producer publish (send) message and Consumer subscribe to the topic to subscribe (read) message.
a Blocking Queue to be used in a multi threaded environment which keeps the order within the partition
Java 8 implementation of the set partition
my solution using dynamic programming for painter's partition problem (problem was posted posted on GeeksforGeeks)
A simple data store library built on top of Git repository
Add a description, image, and links to the partition topic page so that developers can more easily learn about it.
To associate your repository with the partition topic, visit your repo's landing page and select "manage topics."