Abhishek01911

Results 2 issues of Abhishek01911

Summary Resolves Issue [17045](https://github.com/apache/pinot/issues/17045) This PR fixes an issue where an exception in fetchPartitionCount, often caused by a deleted topic, would halt ingestion for an entire multi-topic table. By catching...

kafka
ingestion
bugfix
plugins
real-time

Justification -- The ensureAllPartitionsConsuming function validates and repairs LLC (Low-Level Consumer) realtime segments to ensure all stream partitions have active consuming segments. It's called by the RealtimeSegmentValidationManager periodic task to...

bug
ingestion
real-time