Thomas Bailet

Integration test for web analytics are broken : IncrementalWebSessionIT

1

[ERROR] **testNotOrderedIncomingEventsOneByOneWithConfSessionPlus1** Time elapsed: 4.331 s

pipeline objects (aka processors) are intanciated at each micro-batch by spark executors. This leads to too many objects creation and GC purge. we could instead lazily create a pool of...

implement an in-memory cache service based on https://github.com/ben-manes/caffeine - improve LRU caching with eviction policies (useful for web analytics use case) - better performance

# Expected behavior and actual behavior. # Steps to reproduce the problem. # Specifications like the version of the project, operating system, or hardware.

SchemaRegistry provides a central repository for a message’s metadata. A schema specifies the message structure and type. Schema Registry will allow us to store these schemas efficiently and provides a...

could be done with integration of https://www.hashicorp.com/products/vault/ Vault secures, stores, and tightly controls access to tokens, passwords, certificates, API keys, and other secrets in modern computing. Get started here.

for RGPD : auditing file access from minio or hdfs or any ranger based event can be really usefull https://docs.min.io/docs/minio-bucket-notification-guide.html

# Expected behavior and actual behavior. # Steps to reproduce the problem. # Specifications like the version of the project, operating system, or hardware.

the agent is a service that manages jobs, topics and config to enable live monitoring of logisland streaming jobs use Nitrite as storage features - store job configurations - serve...

# Expected behavior and actual behavior. # Steps to reproduce the problem. # Specifications like the version of the project, operating system, or hardware.