KafkaTridentSpoutTopicPartition (Storm 2.7.1 API)

java.lang.Object
- org.apache.storm.kafka.spout.trident.KafkaTridentSpoutTopicPartition

All Implemented Interfaces:

Serializable, ISpoutPartition
```
public class KafkaTridentSpoutTopicPartition
extends Object
implements ISpoutPartition, Serializable
```
ISpoutPartition that wraps TopicPartition information.

See Also:

Serialized Form

Constructor Summary

Constructors
Constructor	Description
`KafkaTridentSpoutTopicPartition(String topic, int partition)`
`KafkaTridentSpoutTopicPartition(org.apache.kafka.common.TopicPartition topicPartition)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`boolean`	`equals(Object o)`
`String`	`getId()`	This is used as a Zookeeper node path for storing metadata.
`org.apache.kafka.common.TopicPartition`	`getTopicPartition()`
`int`	`hashCode()`
`String`	`toString()`

Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

KafkaTridentSpoutTopicPartition

public KafkaTridentSpoutTopicPartition(String topic,
                                       int partition)

KafkaTridentSpoutTopicPartition

public KafkaTridentSpoutTopicPartition(org.apache.kafka.common.TopicPartition topicPartition)

Method Detail
- getTopicPartition
```
public org.apache.kafka.common.TopicPartition getTopicPartition()
```
- getId
```
public String getId()
```
  Description copied from interface: ISpoutPartition
  
  This is used as a Zookeeper node path for storing metadata.
  
  Specified by:
  
  getId in interface ISpoutPartition
- equals
```
public boolean equals(Object o)
```
  Overrides:
  
  equals in class Object
- hashCode
```
public int hashCode()
```
  Overrides:
  
  hashCode in class Object
- toString
```
public String toString()
```
  Overrides:
  
  toString in class Object