Package org.apache.kafka.common
Class TopicPartition
- java.lang.Object
-
- org.apache.kafka.common.TopicPartition
-
- All Implemented Interfaces:
Serializable
public final class TopicPartition extends Object implements Serializable
A topic name and partition number- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description TopicPartition(String topic, int partition)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(Object obj)
int
hashCode()
int
partition()
void
setTopic(String topic)
ONLY FOR MAPR INTERNAL USE! This method is used only for wrapping a user provided topic with a default stream.String
topic()
String
toString()
-
-
-
Constructor Detail
-
TopicPartition
public TopicPartition(String topic, int partition)
-
-