org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
storageMetadataService.put(
    "TestTopic_8198696fff_90ee0ec3_v1",
    2,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$34(StoreIngestionTaskTest.java:1608)
Actual invocations have different arguments:
storageMetadataService.getLastOffset(
    "TestTopic_8198696fff_90ee0ec3_v1",
    1
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.getLastOffset(
    "TestTopic_8198696fff_90ee0ec3_v1",
    2
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.computeStoreVersionState(
    "TestTopic_8198696fff_90ee0ec3_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$506/858825760@3eb202e2
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_8198696fff_90ee0ec3_v1",
    1,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732848839975, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_8198696fff_90ee0ec3_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$506/858825760@cdc2a0d
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_8198696fff_90ee0ec3_v1",
    1,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732848839975, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_8198696fff_90ee0ec3_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$506/858825760@6f8590eb
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_8198696fff_90ee0ec3_v1",
    1,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732848839975, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_8198696fff_90ee0ec3_v1",
    2,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732848839975, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_8198696fff_90ee0ec3_v1",
    2,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732848839975, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_8198696fff_90ee0ec3_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$506/858825760@20f5b053
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)

	at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$34(StoreIngestionTaskTest.java:1608)
	at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:879)
	at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:773)
	at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:633)
	at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.testNotifier(StoreIngestionTaskTest.java:1584)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:124)
	at org.testng.internal.Invoker.invokeMethod(Invoker.java:583)
	at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:719)
	at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:989)
	at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:125)
	at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:109)
	at org.testng.TestRunner.privateRun(TestRunner.java:648)
	at org.testng.TestRunner.run(TestRunner.java:505)
	at org.testng.SuiteRunner.runTest(SuiteRunner.java:455)
	at org.testng.SuiteRunner.runSequentially(SuiteRunner.java:450)
	at org.testng.SuiteRunner.privateRun(SuiteRunner.java:415)
	at org.testng.SuiteRunner.run(SuiteRunner.java:364)
	at org.testng.SuiteRunnerWorker.runSuite(SuiteRunnerWorker.java:52)
	at org.testng.SuiteRunnerWorker.run(SuiteRunnerWorker.java:84)
	at org.testng.TestNG.runSuitesSequentially(TestNG.java:1208)
	at org.testng.TestNG.runSuitesLocally(TestNG.java:1137)
	at org.testng.TestNG.runSuites(TestNG.java:1049)
	at org.testng.TestNG.run(TestNG.java:1017)

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
storageMetadataService.put(
    "TestTopic_85b669fdc0_cabab160_v1",
    2,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$34(StoreIngestionTaskTest.java:1608)
Actual invocations have different arguments:
storageMetadataService.getLastOffset(
    "TestTopic_85b669fdc0_cabab160_v1",
    1
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.getLastOffset(
    "TestTopic_85b669fdc0_cabab160_v1",
    2
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.computeStoreVersionState(
    "TestTopic_85b669fdc0_cabab160_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$694/1680088294@1735206
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_85b669fdc0_cabab160_v1",
    1,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732848857664, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_85b669fdc0_cabab160_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$694/1680088294@44827fe
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_85b669fdc0_cabab160_v1",
    1,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732848857665, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_85b669fdc0_cabab160_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$694/1680088294@1ae2d1a2
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_85b669fdc0_cabab160_v1",
    1,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732848857665, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_85b669fdc0_cabab160_v1",
    2,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732848857664, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_85b669fdc0_cabab160_v1",
    2,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732848857665, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_85b669fdc0_cabab160_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$694/1680088294@135ccd57
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)

	at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$34(StoreIngestionTaskTest.java:1608)
	at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:879)
	at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:773)
	at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:633)
	at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.testNotifier(StoreIngestionTaskTest.java:1584)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:124)
	at org.testng.internal.Invoker.invokeMethod(Invoker.java:583)
	at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:719)
	at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:989)
	at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:125)
	at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:109)
	at org.testng.TestRunner.privateRun(TestRunner.java:648)
	at org.testng.TestRunner.run(TestRunner.java:505)
	at org.testng.SuiteRunner.runTest(SuiteRunner.java:455)
	at org.testng.SuiteRunner.runSequentially(SuiteRunner.java:450)
	at org.testng.SuiteRunner.privateRun(SuiteRunner.java:415)
	at org.testng.SuiteRunner.run(SuiteRunner.java:364)
	at org.testng.SuiteRunnerWorker.runSuite(SuiteRunnerWorker.java:52)
	at org.testng.SuiteRunnerWorker.run(SuiteRunnerWorker.java:84)
	at org.testng.TestNG.runSuitesSequentially(TestNG.java:1208)
	at org.testng.TestNG.runSuitesLocally(TestNG.java:1137)
	at org.testng.TestNG.runSuites(TestNG.java:1049)
	at org.testng.TestNG.run(TestNG.java:1017)

Wanted but not invoked:
abstractStorageEngine.putWithReplicationMetadata(
    1,
    <any>,
    <any>,
    <any>
);
-> at com.linkedin.davinci.store.AbstractStorageEngine.putWithReplicationMetadata(AbstractStorageEngine.java:487)

However, there were exactly 222 interactions with this mock:
abstractStorageEngine.getStoreVersionName();
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.<init>(DeepCopyStorageEngine.java:35)

abstractStorageEngine.createStoragePartition(
    Replica: null-1000000000, deferred-write: false, read-only: false, write-only: true, read-write leader for default CF: false, read-write leader for RMD CF: false
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.createStoragePartition(DeepCopyStorageEngine.java:53)

abstractStorageEngine.beginBatchWrite(
    Replica: TestTopic_870a93f79f_bd4da7fd_v1-1, deferred-write: false, read-only: false, write-only: true, read-write leader for default CF: false, read-write leader for RMD CF: false,
    {},
    Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.beginBatchWrite(DeepCopyStorageEngine.java:108)

abstractStorageEngine.beginBatchWrite(
    Replica: TestTopic_870a93f79f_bd4da7fd_v1-2, deferred-write: false, read-only: false, write-only: true, read-write leader for default CF: false, read-write leader for RMD CF: false,
    {},
    Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.beginBatchWrite(DeepCopyStorageEngine.java:108)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.beginBatchWrite(
    Replica: TestTopic_870a93f79f_bd4da7fd_v1-1, deferred-write: false, read-only: false, write-only: true, read-write leader for default CF: false, read-write leader for RMD CF: false,
    {},
    Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.beginBatchWrite(DeepCopyStorageEngine.java:108)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x00],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.beginBatchWrite(
    Replica: TestTopic_870a93f79f_bd4da7fd_v1-1, deferred-write: false, read-only: false, write-only: true, read-write leader for default CF: false, read-write leader for RMD CF: false,
    {},
    Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.beginBatchWrite(DeepCopyStorageEngine.java:108)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x01],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.beginBatchWrite(
    Replica: TestTopic_870a93f79f_bd4da7fd_v1-1, deferred-write: false, read-only: false, write-only: true, read-write leader for default CF: false, read-write leader for RMD CF: false,
    {},
    Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.beginBatchWrite(DeepCopyStorageEngine.java:108)

abstractStorageEngine.beginBatchWrite(
    Replica: TestTopic_870a93f79f_bd4da7fd_v1-1, deferred-write: false, read-only: false, write-only: true, read-write leader for default CF: false, read-write leader for RMD CF: false,
    {},
    Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.beginBatchWrite(DeepCopyStorageEngine.java:108)

abstractStorageEngine.sync(1);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.sync(1);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.sync(1);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.sync(1);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.sync(1);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x02],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x03],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x04],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x05],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x06],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x07],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x08],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x09],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x0A],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x0B],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x0C],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x0D],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x0E],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x0F],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x10],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x11],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x12],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x13],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x14],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x15],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x16],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x17],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x18],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x19],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x1A],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x1B],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x1C],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x1D],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x1E],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x1F],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x20],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x21],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x22],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x23],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x24],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x25],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x26],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x27],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x28],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x29],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x2A],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x2B],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x2C],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x2D],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x2E],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x2F],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x30],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x31],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x32],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x33],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x34],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x35],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x36],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x37],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x38],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x39],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x3A],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x3B],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x3C],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x3D],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x3E],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x3F],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x40],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x41],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x42],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x43],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x44],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x45],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x46],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x47],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com

java.lang.AssertionError: expected [1000.0] but found [0.0]
	at org.testng.Assert.fail(Assert.java:96)
	at org.testng.Assert.failNotEquals(Assert.java:776)
	at org.testng.Assert.assertEqualsImpl(Assert.java:137)
	at org.testng.Assert.assertEquals(Assert.java:118)
	at org.testng.Assert.assertEquals(Assert.java:442)
	at com.linkedin.davinci.repository.NativeMetadataRepositoryTest.lambda$testNativeMetadataRepositoryStats$4(NativeMetadataRepositoryTest.java:126)
	at com.linkedin.venice.utils.TestUtils.waitForNonDeterministicAssertion(TestUtils.java:240)
	at com.linkedin.venice.utils.TestUtils.waitForNonDeterministicAssertion(TestUtils.java:225)
	at com.linkedin.venice.utils.TestUtils.waitForNonDeterministicAssertion(TestUtils.java:217)
	at com.linkedin.davinci.repository.NativeMetadataRepositoryTest.testNativeMetadataRepositoryStats(NativeMetadataRepositoryTest.java:123)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:124)
	at org.testng.internal.Invoker.invokeMethod(Invoker.java:583)
	at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:719)
	at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:989)
	at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:125)
	at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:109)
	at org.testng.TestRunner.privateRun(TestRunner.java:648)
	at org.testng.TestRunner.run(TestRunner.java:505)
	at org.testng.SuiteRunner.runTest(SuiteRunner.java:455)
	at org.testng.SuiteRunner.runSequentially(SuiteRunner.java:450)
	at org.testng.SuiteRunner.privateRun(SuiteRunner.java:415)
	at org.testng.SuiteRunner.run(SuiteRunner.java:364)
	at org.testng.SuiteRunnerWorker.runSuite(SuiteRunnerWorker.java:52)
	at org.testng.SuiteRunnerWorker.run(SuiteRunnerWorker.java:84)
	at org.testng.TestNG.runSuitesSequentially(TestNG.java:1208)
	at org.testng.TestNG.runSuitesLocally(TestNG.java:1137)
	at org.testng.TestNG.runSuites(TestNG.java:1049)
	at org.testng.TestNG.run(TestNG.java:1017)

org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet() didn't finish within the time-out 5000
	at jdk.internal.org.objectweb.asm.Frame.pop(Frame.java:759)
	at jdk.internal.org.objectweb.asm.Frame.execute(Frame.java:1227)

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
storageMetadataService.put(
    "TestTopic_8198696fff_90ee0ec3_v1",
    2,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$34(StoreIngestionTaskTest.java:1608)
Actual invocations have different arguments:
storageMetadataService.getLastOffset(
    "TestTopic_8198696fff_90ee0ec3_v1",
    1
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.getLastOffset(
    "TestTopic_8198696fff_90ee0ec3_v1",
    2
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.computeStoreVersionState(
    "TestTopic_8198696fff_90ee0ec3_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$506/858825760@3eb202e2
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_8198696fff_90ee0ec3_v1",
    1,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732848839975, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_8198696fff_90ee0ec3_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$506/858825760@cdc2a0d
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_8198696fff_90ee0ec3_v1",
    1,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732848839975, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_8198696fff_90ee0ec3_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$506/858825760@6f8590eb
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_8198696fff_90ee0ec3_v1",
    1,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732848839975, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_8198696fff_90ee0ec3_v1",
    2,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732848839975, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_8198696fff_90ee0ec3_v1",
    2,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732848839975, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_8198696fff_90ee0ec3_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$506/858825760@20f5b053
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)

	at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$34(StoreIngestionTaskTest.java:1608)
	at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:879)
	at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:773)
	at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:633)
	at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.testNotifier(StoreIngestionTaskTest.java:1584)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:124)
	at org.testng.internal.Invoker.invokeMethod(Invoker.java:583)
	at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:719)
	at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:989)
	at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:125)
	at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:109)
	at org.testng.TestRunner.privateRun(TestRunner.java:648)
	at org.testng.TestRunner.run(TestRunner.java:505)
	at org.testng.SuiteRunner.runTest(SuiteRunner.java:455)
	at org.testng.SuiteRunner.runSequentially(SuiteRunner.java:450)
	at org.testng.SuiteRunner.privateRun(SuiteRunner.java:415)
	at org.testng.SuiteRunner.run(SuiteRunner.java:364)
	at org.testng.SuiteRunnerWorker.runSuite(SuiteRunnerWorker.java:52)
	at org.testng.SuiteRunnerWorker.run(SuiteRunnerWorker.java:84)
	at org.testng.TestNG.runSuitesSequentially(TestNG.java:1208)
	at org.testng.TestNG.runSuitesLocally(TestNG.java:1137)
	at org.testng.TestNG.runSuites(TestNG.java:1049)
	at org.testng.TestNG.run(TestNG.java:1017)

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
storageMetadataService.put(
    "TestTopic_85b669fdc0_cabab160_v1",
    2,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$34(StoreIngestionTaskTest.java:1608)
Actual invocations have different arguments:
storageMetadataService.getLastOffset(
    "TestTopic_85b669fdc0_cabab160_v1",
    1
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.getLastOffset(
    "TestTopic_85b669fdc0_cabab160_v1",
    2
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.computeStoreVersionState(
    "TestTopic_85b669fdc0_cabab160_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$694/1680088294@1735206
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_85b669fdc0_cabab160_v1",
    1,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732848857664, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_85b669fdc0_cabab160_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$694/1680088294@44827fe
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_85b669fdc0_cabab160_v1",
    1,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732848857665, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_85b669fdc0_cabab160_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$694/1680088294@1ae2d1a2
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
    "TestTopic_85b669fdc0_cabab160_v1",
    1,
    OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732848857665, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_85b669fdc0_cabab160_v1",
    2,
    OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732848857664, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
    "TestTopic_85b669fdc0_cabab160_v1",
    2,
    OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1732848857665, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
    "TestTopic_85b669fdc0_cabab160_v1",
    com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$694/1680088294@135ccd57
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)

	at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$34(StoreIngestionTaskTest.java:1608)
	at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:879)
	at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:773)
	at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:633)
	at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.testNotifier(StoreIngestionTaskTest.java:1584)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:124)
	at org.testng.internal.Invoker.invokeMethod(Invoker.java:583)
	at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:719)
	at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:989)
	at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:125)
	at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:109)
	at org.testng.TestRunner.privateRun(TestRunner.java:648)
	at org.testng.TestRunner.run(TestRunner.java:505)
	at org.testng.SuiteRunner.runTest(SuiteRunner.java:455)
	at org.testng.SuiteRunner.runSequentially(SuiteRunner.java:450)
	at org.testng.SuiteRunner.privateRun(SuiteRunner.java:415)
	at org.testng.SuiteRunner.run(SuiteRunner.java:364)
	at org.testng.SuiteRunnerWorker.runSuite(SuiteRunnerWorker.java:52)
	at org.testng.SuiteRunnerWorker.run(SuiteRunnerWorker.java:84)
	at org.testng.TestNG.runSuitesSequentially(TestNG.java:1208)
	at org.testng.TestNG.runSuitesLocally(TestNG.java:1137)
	at org.testng.TestNG.runSuites(TestNG.java:1049)
	at org.testng.TestNG.run(TestNG.java:1017)

Wanted but not invoked:
abstractStorageEngine.putWithReplicationMetadata(
    1,
    <any>,
    <any>,
    <any>
);
-> at com.linkedin.davinci.store.AbstractStorageEngine.putWithReplicationMetadata(AbstractStorageEngine.java:487)

However, there were exactly 222 interactions with this mock:
abstractStorageEngine.getStoreVersionName();
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.<init>(DeepCopyStorageEngine.java:35)

abstractStorageEngine.createStoragePartition(
    Replica: null-1000000000, deferred-write: false, read-only: false, write-only: true, read-write leader for default CF: false, read-write leader for RMD CF: false
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.createStoragePartition(DeepCopyStorageEngine.java:53)

abstractStorageEngine.beginBatchWrite(
    Replica: TestTopic_870a93f79f_bd4da7fd_v1-1, deferred-write: false, read-only: false, write-only: true, read-write leader for default CF: false, read-write leader for RMD CF: false,
    {},
    Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.beginBatchWrite(DeepCopyStorageEngine.java:108)

abstractStorageEngine.beginBatchWrite(
    Replica: TestTopic_870a93f79f_bd4da7fd_v1-2, deferred-write: false, read-only: false, write-only: true, read-write leader for default CF: false, read-write leader for RMD CF: false,
    {},
    Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.beginBatchWrite(DeepCopyStorageEngine.java:108)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.beginBatchWrite(
    Replica: TestTopic_870a93f79f_bd4da7fd_v1-1, deferred-write: false, read-only: false, write-only: true, read-write leader for default CF: false, read-write leader for RMD CF: false,
    {},
    Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.beginBatchWrite(DeepCopyStorageEngine.java:108)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x00],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.beginBatchWrite(
    Replica: TestTopic_870a93f79f_bd4da7fd_v1-1, deferred-write: false, read-only: false, write-only: true, read-write leader for default CF: false, read-write leader for RMD CF: false,
    {},
    Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.beginBatchWrite(DeepCopyStorageEngine.java:108)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x01],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.beginBatchWrite(
    Replica: TestTopic_870a93f79f_bd4da7fd_v1-1, deferred-write: false, read-only: false, write-only: true, read-write leader for default CF: false, read-write leader for RMD CF: false,
    {},
    Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.beginBatchWrite(DeepCopyStorageEngine.java:108)

abstractStorageEngine.beginBatchWrite(
    Replica: TestTopic_870a93f79f_bd4da7fd_v1-1, deferred-write: false, read-only: false, write-only: true, read-write leader for default CF: false, read-write leader for RMD CF: false,
    {},
    Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.beginBatchWrite(DeepCopyStorageEngine.java:108)

abstractStorageEngine.sync(1);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.sync(1);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.sync(1);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.sync(1);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.sync(1);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x02],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x03],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x04],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x05],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x06],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x07],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x08],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x09],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x0A],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x0B],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x0C],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x0D],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x0E],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x0F],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x10],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x11],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x12],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x13],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x14],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x15],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x16],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x17],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x18],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x19],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x1A],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x1B],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x1C],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x1D],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x1E],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x1F],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x20],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x21],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x22],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x23],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x24],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x25],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x26],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x27],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x28],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x29],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x2A],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x2B],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x2C],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x2D],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x2E],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x2F],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x30],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x31],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x32],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x33],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x34],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x35],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x36],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x37],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x38],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x39],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x3A],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x3B],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x3C],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x3D],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x3E],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x3F],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x40],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x41],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x42],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x43],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x44],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x45],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x46],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.sync(DeepCopyStorageEngine.java:178)

abstractStorageEngine.put(
    2,
    [(byte) 0x02, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x32, (byte) 0x5F, (byte) 0x35, (byte) 0x38, (byte) 0x61, (byte) 0x30, (byte) 0x34, (byte) 0x39, (byte) 0x65, (byte) 0x31, (byte) 0x39, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x63, (byte) 0x30, (byte) 0x65, (byte) 0x66, (byte) 0x36, (byte) 0x65, (byte) 0x63, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x47],
    java.nio.HeapByteBuffer[pos=0 lim=21 cap=21]
);
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:143)

abstractStorageEngine.sync(2);
-> at com

java.lang.AssertionError: expected [1000.0] but found [0.0]
	at org.testng.Assert.fail(Assert.java:96)
	at org.testng.Assert.failNotEquals(Assert.java:776)
	at org.testng.Assert.assertEqualsImpl(Assert.java:137)
	at org.testng.Assert.assertEquals(Assert.java:118)
	at org.testng.Assert.assertEquals(Assert.java:442)
	at com.linkedin.davinci.repository.NativeMetadataRepositoryTest.lambda$testNativeMetadataRepositoryStats$4(NativeMetadataRepositoryTest.java:126)
	at com.linkedin.venice.utils.TestUtils.waitForNonDeterministicAssertion(TestUtils.java:240)
	at com.linkedin.venice.utils.TestUtils.waitForNonDeterministicAssertion(TestUtils.java:225)
	at com.linkedin.venice.utils.TestUtils.waitForNonDeterministicAssertion(TestUtils.java:217)
	at com.linkedin.davinci.repository.NativeMetadataRepositoryTest.testNativeMetadataRepositoryStats(NativeMetadataRepositoryTest.java:123)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:124)
	at org.testng.internal.Invoker.invokeMethod(Invoker.java:583)
	at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:719)
	at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:989)
	at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:125)
	at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:109)
	at org.testng.TestRunner.privateRun(TestRunner.java:648)
	at org.testng.TestRunner.run(TestRunner.java:505)
	at org.testng.SuiteRunner.runTest(SuiteRunner.java:455)
	at org.testng.SuiteRunner.runSequentially(SuiteRunner.java:450)
	at org.testng.SuiteRunner.privateRun(SuiteRunner.java:415)
	at org.testng.SuiteRunner.run(SuiteRunner.java:364)
	at org.testng.SuiteRunnerWorker.runSuite(SuiteRunnerWorker.java:52)
	at org.testng.SuiteRunnerWorker.run(SuiteRunnerWorker.java:84)
	at org.testng.TestNG.runSuitesSequentially(TestNG.java:1208)
	at org.testng.TestNG.runSuitesLocally(TestNG.java:1137)
	at org.testng.TestNG.runSuites(TestNG.java:1049)
	at org.testng.TestNG.run(TestNG.java:1017)

org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet() didn't finish within the time-out 5000
	at jdk.internal.org.objectweb.asm.Frame.pop(Frame.java:759)
	at jdk.internal.org.objectweb.asm.Frame.execute(Frame.java:1227)