hermes
hermes copied to clipboard
allegro
Fast and reliable message broker built on top of Kafka.
### Backward incompatible changes Changed the following metrics paths (removed `selective` from the paths): * `consumer.{hostname}.consumers-workload.{kafkaCluster}.selective.rebalance-duration` -> `consumer.{hostname}.consumers-workload.{kafkaCluster}.rebalance-duration` * `consumer.{hostname}.consumers-workload.{kafkaCluster}.selective.all-assignments` -> `consumer.{hostname}.consumers-workload.{kafkaCluster}.all-assignments` * `consumer.{hostname}.consumers-workload.{kafkaCluster}.selective.missing-resources` -> `consumer.{hostname}.consumers-workload.{kafkaCluster}.missing-resources` * `consumer.{hostname}.consumers-workload.{kafkaCluster}.selective.deleted-assignments` -> `consumer.{hostname}.consumers-workload.{kafkaCluster}.deleted-assignments`...
This PR introduces consumer load metrics that will be used by the weighted work balancer. For now, I want to start with one metric: the number of operations per second...
[](https://medium.com/@jonathan.leitschuh/want-to-take-over-the-java-ecosystem-all-you-need-is-a-mitm-1fc329d898fb?source=friends_link&sk=3c99970c55a899ad9ef41f126efcde0e) --- This is a security fix for a high-severity vulnerability in your [Gradle](https://gradle.org/) `build.gradle` file(s). The build files indicate that this project is resolving dependencies over HTTP instead of...
- Removed field injections by `Autowired` annotation - Removed unused code - Fixed some small code warnings
It looks like sometimes ZooKeeper is not ready after 120 seconds (path `/hermes/groups` is not created). **Where it fails:** ```java private void waitUntilStructureInZookeeperIsCreated(CuratorFramework zookeeper) { waitAtMost(adjust(120), TimeUnit.SECONDS).until(() -> zookeeper.checkExists().forPath("/hermes/groups") !=...
How it fails: ``` 2022-02-02T14:08:30.5596264Z Gradle suite > Gradle test > pl.allegro.tech.hermes.integration.PublishingTest > shouldPublishWithDelayAndConsumeMessage FAILED 2022-02-02T14:08:30.5596790Z java.lang.AssertionError: 2022-02-02T14:08:30.5597018Z Expecting: 2022-02-02T14:08:30.5597219Z 2022-02-02T14:08:30.5597412Z to contain: 2022-02-02T14:08:30.5597608Z 2022-02-02T14:08:30.5597838Z but could not find: 2022-02-02T14:08:30.5598059Z...