org.apache.flink.statefun.sdk.kafka

Class KafkaTopicPartition

java.lang.Object

org.apache.flink.statefun.sdk.kafka.KafkaTopicPartition

public final class KafkaTopicPartition
extends java.lang.Object

Representation of a Kafka partition.

Constructor Summary

Constructors

Constructor and Description
KafkaTopicPartition(java.lang.String topic, int partition)

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object o)
static KafkaTopicPartition	fromString(java.lang.String topicAndPartition)
int	hashCode()
int	partition()
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

KafkaTopicPartition

public KafkaTopicPartition(java.lang.String topic,
                           int partition)

Method Detail

fromString

public static KafkaTopicPartition fromString(java.lang.String topicAndPartition)

topic

public java.lang.String topic()

partition

public int partition()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

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