root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 3 Packages Projects Releases Wiki Activity

MINOR: remove unnecessary logging (#15396) 

We already record dropping record via metrics and logging at WARN level
is too noise. This PR removes the unnecessary logging.

Reviewers: Kalpesh Patel <kpatel@confluent.io>, Walker Carlson <wcarlson@confluent.io>, Lucas Brutschy <lbrutschy@confluent.io>
This commit is contained in:
Matthias J. Sax 2024-02-21 08:01:11 -08:00 committed by GitHub
parent 4c012c5c23
commit a3528a316f
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 0 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStore.java
View File

@ -264,7 +264,6 @@ public class AbstractRocksDBSegmentedBytesStore<S extends Segment> implements Se
final S segment = segments.getOrCreateSegmentIfLive(segmentId, context, observedStreamTime); final S segment = segments.getOrCreateSegmentIfLive(segmentId, context, observedStreamTime);
if (segment == null) { if (segment == null) {
expiredRecordSensor.record(1.0d, context.currentSystemTimeMs()); expiredRecordSensor.record(1.0d, context.currentSystemTimeMs());
LOG.warn("Skipping record for expired segment.");
} else { } else {
synchronized (position) { synchronized (position) {
StoreQueryUtils.updatePosition(position, stateStoreContext); StoreQueryUtils.updatePosition(position, stateStoreContext);