com.opendxl.databus.common

Class PartitionInfo

java.lang.Object

com.opendxl.databus.common.PartitionInfo

public final class PartitionInfo
extends java.lang.Object

Information about a topic-partition. An object of this class is built only for Databus as a result of a Producer.partitionsFor(String) method

Constructor Summary

Constructors

Constructor and Description
PartitionInfo(java.lang.String topic, int partition, Node leader, Node[] replicas, Node[] inSyncReplicas)

Method Summary

Modifier and Type	Method and Description
Node[]	inSyncReplicas()
Node	leader()
int	partition()
Node[]	replicas()
java.lang.String	topic()
java.lang.String	toString()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

PartitionInfo

public PartitionInfo(java.lang.String topic,
                     int partition,
                     Node leader,
                     Node[] replicas,
                     Node[] inSyncReplicas)

Method Detail

topic

public java.lang.String topic()

Returns:

topic name

partition

public int partition()

Returns:

partition number

leader

public Node leader()

Returns:

leader node

replicas

public Node[] replicas()

Returns:

replica nodes

inSyncReplicas

public Node[] inSyncReplicas()

Returns:

replica nodes

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

Returns:

this getInstance as String