org.oracle.okafka.common

Class PartitionInfo

java.lang.Object

org.oracle.okafka.common.PartitionInfo

public class PartitionInfo
extends java.lang.Object

This is used to describe per-partition state in the MetadataResponse.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
Node[]	inSyncReplicas() All oracle db instances run on same disk, so there is no need of replicating data among instances.
Node	leader() The Node currently acting as a leader for this partition or null if there is no leader
Node[]	offlineReplicas() All oracle db instances run on same disk, so there is no need of replicating data among instances.
int	partition() The partition id
Node[]	replicas() All oracle db instances run on same disk, so there is no need of replicating data among instances.
java.lang.String	topic() The topic name
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

PartitionInfo

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

PartitionInfo

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

Method Detail

topic

public java.lang.String topic()

The topic name

partition

public int partition()

The partition id

leader

public Node leader()

The Node currently acting as a leader for this partition or null if there is no leader

replicas

public Node[] replicas()

All oracle db instances run on same disk, so there is no need of replicating data among instances.

Returns:

null since there is no replication.

inSyncReplicas

public Node[] inSyncReplicas()

All oracle db instances run on same disk, so there is no need of replicating data among instances.

Returns:

null since there is no replication.

offlineReplicas

public Node[] offlineReplicas()

All oracle db instances run on same disk, so there is no need of replicating data among instances.

Returns:

null since there is no replication.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object