vvcephei commented on a change in pull request #8896:
URL: https://github.com/apache/kafka/pull/8896#discussion_r442529975
##########
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java
##########
@@ -496,8 +539,9 @@ private void bufferChangelogRecords(final ChangelogMetadata
changelogMetadata, f
} else {
changelogMetadata.bufferedRecords.add(record);
final long offset = record.offset();
- if (changelogMetadata.restoreEndOffset == null || offset <
changelogMetadata.restoreEndOffset)
+ if (changelogMetadata.restoreEndOffset == null || offset <
changelogMetadata.restoreEndOffset) {
changelogMetadata.bufferedLimitIndex =
changelogMetadata.bufferedRecords.size();
+ }
Review comment:
I've rolled back a bunch of accidental formatting changes, but left the
ones that are actually code style compliance issues (like using brackets around
conditional bodies).
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
