search

DataCater / datacater

The developer-friendly ETL platform for transforming data in real-time. Based on Apache Kafka® and Kubernetes®.
https://datacater.io
Other
82 stars 4 forks source link

fix(stream-inspect): change message retrieval method #158

Closed ChrisRousey closed 1 year ago

ChrisRousey commented 1 year ago

This PR adds a new method to retrieve messages from partitions: The new method will first get messages from partition1, if the expected amount is not yet reached, the amount is filled with messages from aprtition 2 and so on

ChrisRousey commented 1 year ago

FYI i also opened a CR in GitBook for documenting these changes.

sonarcloud[bot] commented 1 year ago

Kudos, SonarCloud Quality Gate passed!    Quality Gate passed

Bug A 0 Bugs
Vulnerability A 0 Vulnerabilities
Security Hotspot A 0 Security Hotspots
Code Smell A 0 Code Smells

94.4% 94.4% Coverage
0.0% 0.0% Duplication