2a61b97fab
1. RecordEmitter logic refactored - all polling logic moved RangePollingEmitter. Backward/Forward implementations just chouse how range is calculated for next step. 2. Using consumer.position() method to define that range is fully polled (not empty polls counting deleted) 3. AnalysisTask: calculating progress based on processed offsets, not polled messages (more accurate for compacted topics) 4. Sorting polled messages by ts before sending to frontend |
||
|---|---|---|
| .. | ||
| src | ||
| Dockerfile | ||
| pom.xml | ||