Interface RoutingDataRepository.RoutingDataChangedListener

    • Method Detail

      • 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​(java.lang.String topic,
                                     ReadOnlyPartitionStatus partitionStatus)
      • onRoutingDataDeleted

        void onRoutingDataDeleted​(java.lang.String kafkaTopic)