Class AssignmentInfo


  • public class AssignmentInfo
    extends java.lang.Object
    • Constructor Summary

      Constructors 
      Constructor Description
      AssignmentInfo​(int version, int commonlySupportedVersion)  
      AssignmentInfo​(int version, int commonlySupportedVersion, java.util.List<TaskId> activeTasks, java.util.Map<TaskId,​java.util.Set<org.apache.kafka.common.TopicPartition>> standbyTasks, java.util.Map<HostInfo,​java.util.Set<org.apache.kafka.common.TopicPartition>> partitionsByHost, java.util.Map<HostInfo,​java.util.Set<org.apache.kafka.common.TopicPartition>> standbyPartitionsByHost, int errCode)  
      AssignmentInfo​(int version, java.util.List<TaskId> activeTasks, java.util.Map<TaskId,​java.util.Set<org.apache.kafka.common.TopicPartition>> standbyTasks, java.util.Map<HostInfo,​java.util.Set<org.apache.kafka.common.TopicPartition>> partitionsByHost, java.util.Map<HostInfo,​java.util.Set<org.apache.kafka.common.TopicPartition>> standbyPartitionsByHost, int errCode)  
    • Constructor Detail

      • AssignmentInfo

        public AssignmentInfo​(int version,
                              int commonlySupportedVersion)
      • AssignmentInfo

        public AssignmentInfo​(int version,
                              java.util.List<TaskId> activeTasks,
                              java.util.Map<TaskId,​java.util.Set<org.apache.kafka.common.TopicPartition>> standbyTasks,
                              java.util.Map<HostInfo,​java.util.Set<org.apache.kafka.common.TopicPartition>> partitionsByHost,
                              java.util.Map<HostInfo,​java.util.Set<org.apache.kafka.common.TopicPartition>> standbyPartitionsByHost,
                              int errCode)
      • AssignmentInfo

        public AssignmentInfo​(int version,
                              int commonlySupportedVersion,
                              java.util.List<TaskId> activeTasks,
                              java.util.Map<TaskId,​java.util.Set<org.apache.kafka.common.TopicPartition>> standbyTasks,
                              java.util.Map<HostInfo,​java.util.Set<org.apache.kafka.common.TopicPartition>> partitionsByHost,
                              java.util.Map<HostInfo,​java.util.Set<org.apache.kafka.common.TopicPartition>> standbyPartitionsByHost,
                              int errCode)
    • Method Detail

      • setNextRebalanceTime

        public void setNextRebalanceTime​(long nextRebalanceTimeMs)
      • version

        public int version()
      • errCode

        public int errCode()
      • commonlySupportedVersion

        public int commonlySupportedVersion()
      • activeTasks

        public java.util.List<TaskId> activeTasks()
      • standbyTasks

        public java.util.Map<TaskId,​java.util.Set<org.apache.kafka.common.TopicPartition>> standbyTasks()
      • partitionsByHost

        public java.util.Map<HostInfo,​java.util.Set<org.apache.kafka.common.TopicPartition>> partitionsByHost()
      • standbyPartitionByHost

        public java.util.Map<HostInfo,​java.util.Set<org.apache.kafka.common.TopicPartition>> standbyPartitionByHost()
      • nextRebalanceMs

        public long nextRebalanceMs()
      • encode

        public java.nio.ByteBuffer encode()
        Throws:
        TaskAssignmentException - if method fails to encode the data, e.g., if there is an IO exception during encoding
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object
      • equals

        public boolean equals​(java.lang.Object o)
        Overrides:
        equals in class java.lang.Object
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object