3 aggregator#4
Merged
Merged
Conversation
LightInTheFire
added a commit
that referenced
this pull request
Mar 10, 2026
* 2 collector grpc (#3) * feat: add hub and sensor proto schemas * feat: add grpc * Normalize line endings to LF * spotless apply * feat: add gitattr * fix crlf * 3 aggregator (#4) * feat: add sensor snapshot avdl protocol * feat: add base for Aggregator app module * feat: add dependencies * feat: implement avro serializer and deserializers * feat: add kafka config properties * feat: add Producer and Consumer kafka autoconfigurations * feat: implement snapshot and aggregation service * feat: implement kafka event loop runner * 4 analyzer (#5) * feat: add run configs to project * feat: add database to compose file * feat: add analyzer module * feat: add testcontainers run class and application properties * feat: add schema.sql * spotless apply * feat: update prod properties * feat: add hubrouter controller proto * chore: rename runner to proccesor * feat: move avro serializers and deserializers to avro module * feat: add hubevent and snapshot avro deserializers * feat: add schema dependencies * feat: add kafka consumers properties * feat: add KafkaConsumer beans * feat: log on deserialization error * feat: update scripts to correctly show text in terminal * remove unused imports * feat: add persistence models * feat: add jpa repositories for model * feat: add grpc client dependency and it's configuration * feat: change String types in models to enums * feat: add builder to model * update gitignore * feat: add hubrouter client * feat: add validation dependency * feat: add hub events handling * fix: hub client now accepts array * feat: implement snapshot service * feat: add processors to start kafka listeners * fix * fix run config * feat: remove devtools * spottless apply * fix: inject correct config * rename Snapshot service to Snapshot Cache service * fix consumer closing warn thread fixes (#7) * fix: add null check in SnapshotService * fix: remove unnecessary .put() call * fix: add flush method * fix: delete sensors by id and hub id * spotless apply * fix: add producer flush calls
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
1 participant
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Add aggregation service