Interface RoutingDataRepository.RoutingDataChangedListener

All Known Implementing Classes:
AbstractPushMonitor, AggPartitionHealthStats, PartitionStatusBasedPushMonitor, ReadQuotaEnforcementHandler
Enclosing interface:
RoutingDataRepository

public static interface RoutingDataRepository.RoutingDataChangedListener
  • Method Details

    • onExternalViewChange

      void onExternalViewChange(PartitionAssignment partitionAssignment)
      Handle routing data changed event.
      Parameters:
      partitionAssignment - Newest partitions assignments information including resource name and all of instances assigned to this resource. If the number of partition is 0, it means the kafka topic is deleted.
    • onCustomizedViewChange

      void onCustomizedViewChange(PartitionAssignment partitionAssignment)
    • onCustomizedViewAdded

      void onCustomizedViewAdded(PartitionAssignment partitionAssignment)
    • onPartitionStatusChange

      void onPartitionStatusChange(String topic, ReadOnlyPartitionStatus partitionStatus)
    • onRoutingDataDeleted

      void onRoutingDataDeleted(String kafkaTopic)