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
