@Immutable @ParametersAreNonnullByDefault public class TopologyViewDiff extends Object
Constructor and Description |
---|
TopologyViewDiff(TopologyView oldView,
TopologyView newView) |
Modifier and Type | Method and Description |
---|---|
Map<String,Supplier<LongStream>> |
getProcessedOffsets()
Return the map of the processed offsets, from the old and new view, per publisher agent.
|
public TopologyViewDiff(TopologyView oldView, TopologyView newView)
public Map<String,Supplier<LongStream>> getProcessedOffsets()
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.