philipnee commented on code in PR #13269: URL: https://github.com/apache/kafka/pull/13269#discussion_r1156196422
########## streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java: ########## @@ -1692,43 +1699,45 @@ public void shouldReturnOffsetsForRepartitionTopicsForPurging() { final TopicPartition repartition = new TopicPartition("repartition", 1); final ProcessorTopology topology = withRepartitionTopics( - asList(source1, source2), - mkMap(mkEntry(topic1, source1), mkEntry(repartition.topic(), source2)), - singleton(repartition.topic()) + asList(source1, source2), + mkMap(mkEntry(topic1, source1), mkEntry(repartition.topic(), source2)), + singleton(repartition.topic()) ); consumer.assign(asList(partition1, repartition)); consumer.updateBeginningOffsets(mkMap(mkEntry(repartition, 0L))); - EasyMock.expect(stateManager.changelogPartitions()).andReturn(Collections.emptySet()); + EasyMock.expect(stateManager.changelogOffsets()).andStubReturn(Collections.emptyMap()); // restoration checkpoint + EasyMock.expect(stateManager.changelogPartitions()).andStubReturn(Collections.emptySet()); EasyMock.expect(recordCollector.offsets()).andReturn(emptyMap()).anyTimes(); EasyMock.replay(stateManager, recordCollector); final StreamsConfig config = createConfig(); final InternalProcessorContext context = new ProcessorContextImpl( - taskId, - config, - stateManager, - streamsMetrics, - null + taskId, + config, + stateManager, + streamsMetrics, + null ); task = new StreamTask( - taskId, - mkSet(partition1, repartition), - topology, - consumer, - new TopologyConfig(null, config, new Properties()).getTaskConfig(), - streamsMetrics, - stateDirectory, - cache, - time, - stateManager, - recordCollector, - context, - logContext); + taskId, + mkSet(partition1, repartition), + topology, + consumer, + new TopologyConfig(null, config, new Properties()).getTaskConfig(), + streamsMetrics, + stateDirectory, + cache, + time, + stateManager, + recordCollector, + context, + logContext); Review Comment: Sorry! I think I'm in the habit of using 8 spaces for "continuous indentation". -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org