This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 6a30b4e MINOR: equals() should check _unknownTaggedFields (#8640) add ad4b12a KAFKA-10005: Decouple RestoreListener from RestoreCallback (#8676) No new revisions were added by this update. Summary of changes: .../AbstractNotifyingBatchingRestoreCallback.java | 83 -------- .../AbstractNotifyingRestoreCallback.java | 72 ------- .../processor/BatchingStateRestoreCallback.java | 4 + .../streams/processor/StateRestoreListener.java | 9 +- .../processor/internals/ChangelogRegister.java | 3 +- .../internals/CompositeRestoreListener.java | 116 ----------- .../processor/internals/ProcessorStateManager.java | 18 +- .../RecordBatchingStateRestoreCallback.java | 5 - .../processor/internals/StoreChangelogReader.java | 48 +---- .../AbstractRocksDBSegmentedBytesStore.java | 43 +--- ...ulkLoadingStore.java => BatchWritingStore.java} | 3 +- .../streams/state/internals/RocksDBStore.java | 60 +----- .../state/internals/RocksDBTimestampedStore.java | 15 -- .../kafka/streams/state/internals/Segment.java | 2 +- .../internals/CompositeRestoreListenerTest.java | 222 --------------------- .../processor/internals/MockChangelogReader.java | 2 +- .../internals/ProcessorStateManagerTest.java | 18 +- .../internals/StoreChangelogReaderTest.java | 85 +------- .../AbstractRocksDBSegmentedBytesStoreTest.java | 31 --- .../internals/RocksDBSegmentedBytesStoreTest.java | 7 - .../streams/state/internals/RocksDBStoreTest.java | 50 ----- .../RocksDBTimestampedSegmentedBytesStoreTest.java | 7 - .../kafka/test/InternalMockProcessorContext.java | 20 -- .../test/MockBatchingStateRestoreListener.java | 44 ---- .../org/apache/kafka/test/MockRestoreCallback.java | 1 - .../kafka/test/MockStateRestoreListener.java | 14 +- 26 files changed, 39 insertions(+), 943 deletions(-) delete mode 100644 streams/src/main/java/org/apache/kafka/streams/processor/AbstractNotifyingBatchingRestoreCallback.java delete mode 100644 streams/src/main/java/org/apache/kafka/streams/processor/AbstractNotifyingRestoreCallback.java delete mode 100644 streams/src/main/java/org/apache/kafka/streams/processor/internals/CompositeRestoreListener.java rename streams/src/main/java/org/apache/kafka/streams/state/internals/{BulkLoadingStore.java => BatchWritingStore.java} (91%) delete mode 100644 streams/src/test/java/org/apache/kafka/streams/processor/internals/CompositeRestoreListenerTest.java delete mode 100644 streams/src/test/java/org/apache/kafka/test/MockBatchingStateRestoreListener.java