Class AssignmentInfo


  • public class AssignmentInfo
    extends java.lang.Object
    • Field Detail

      • LATEST_SUPPORTED_VERSION

        public static final int LATEST_SUPPORTED_VERSION
        See Also:
        Constant Field Values
    • Constructor Detail

      • AssignmentInfo

        public AssignmentInfo​(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>> hostState)
      • AssignmentInfo

        public AssignmentInfo()
      • 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>> hostState,
                              int errCode)
    • Method Detail

      • version

        public int version()
      • errCode

        public int errCode()
      • latestSupportedVersion

        public int latestSupportedVersion()
      • 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()
      • 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