@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.
|
boolean |
subscribedAgentsChanged() |
public TopologyViewDiff(TopologyView oldView, TopologyView newView)
public Map<String,Supplier<LongStream>> getProcessedOffsets()
public boolean subscribedAgentsChanged()
true
if the set of subscribed agent changed between the old and new view ;
false
otherwise.Copyright © 2007–2021 The Apache Software Foundation. All rights reserved.