vrajat commented on code in PR #12157: URL: https://github.com/apache/pinot/pull/12157#discussion_r1473780427
########## pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeSegmentDataManager.java: ########## @@ -1648,6 +1648,15 @@ private void makeStreamConsumer(String reason) { _segmentLogger.info("Creating new stream consumer for topic partition {} , reason: {}", _clientId, reason); _partitionGroupConsumer = _streamConsumerFactory.createPartitionGroupConsumer(_clientId, _partitionGroupConsumptionStatus); + try { + _partitionGroupConsumer.validateStreamState(_currentOffset); + _serverMetrics.setValueOfPartitionGauge(_tableNameWithType, 0, + ServerGauge.INVALID_REALTIME_STREAM_STATE_EXCEPTION, 0); + } catch (PermanentConsumerException pce) { Review Comment: Going back on this. On more discussion, it is a bad idea to stop ingestion as that will cause more data loss. So the decision right now is to alert but not stop. Also not that the same condition is checked in `RealtimeDataValidationManager` and that increases a meter but does not attempt to stop. So there is a precedent. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org For additional commands, e-mail: commits-h...@pinot.apache.org