Spring Integration Kafka Support

org.springframework.integration.kafka.core
Class Partition

java.lang.Object
  extended by org.springframework.integration.kafka.core.Partition

public class Partition
extends java.lang.Object

A reference to a Kafka partition, with both topic and partition id

Author:
Marius Bogoevici

Constructor Summary
Partition(java.lang.String topic, int id)
           
 
Method Summary
 boolean equals(java.lang.Object o)
           
 int getId()
           
 java.lang.String getTopic()
           
 int hashCode()
           
 void setId(int id)
           
 void setTopic(java.lang.String topic)
           
 java.lang.String toString()
           
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 

Constructor Detail

Partition

public Partition(java.lang.String topic,
                 int id)
Method Detail

getTopic

public java.lang.String getTopic()

setTopic

public void setTopic(java.lang.String topic)

getId

public int getId()

setId

public void setId(int id)

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

Spring Integration Kafka Support