Class TopologyViewDiff

    • Method Detail

      • getProcessedOffsets

        public Map<String,​Supplier<LongStream>> getProcessedOffsets()
        Return the map of the processed offsets, from the old and new view, per publisher agent.
        Returns:
        a map (pubAgentName x processedOffsets)
      • subscribedAgentsChanged

        public boolean subscribedAgentsChanged()
        Returns:
        true if the set of subscribed agent changed between the old and new view ; false otherwise.