public class KafkaETLRequest
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static long |
DEFAULT_OFFSET |
static java.lang.String |
DELIM |
Constructor and Description |
---|
KafkaETLRequest() |
KafkaETLRequest(java.lang.String input) |
KafkaETLRequest(java.lang.String topic,
java.lang.String uri,
int partition) |
KafkaETLRequest(java.lang.String node,
java.lang.String topic,
java.lang.String partition,
java.lang.String offset,
java.util.Map<java.lang.String,java.lang.String> nodes) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
clientId() |
boolean |
equals(java.lang.Object o) |
long |
getOffset() |
int |
getPartition() |
java.lang.String |
getTopic() |
java.net.URI |
getURI() |
int |
hashCode() |
boolean |
isValidOffset() |
void |
setDefaultOffset() |
void |
setOffset(long offset) |
java.lang.String |
toString() |
java.lang.String |
toString(long offset) |
public static long DEFAULT_OFFSET
public static java.lang.String DELIM
public KafkaETLRequest()
public KafkaETLRequest(java.lang.String input) throws java.io.IOException
java.io.IOException
public KafkaETLRequest(java.lang.String node, java.lang.String topic, java.lang.String partition, java.lang.String offset, java.util.Map<java.lang.String,java.lang.String> nodes) throws java.io.IOException
java.io.IOException
public KafkaETLRequest(java.lang.String topic, java.lang.String uri, int partition) throws java.net.URISyntaxException
java.net.URISyntaxException
public void setDefaultOffset()
public void setOffset(long offset)
public java.lang.String getTopic()
public java.net.URI getURI()
public int getPartition()
public long getOffset()
public java.lang.String clientId()
public boolean isValidOffset()
public boolean equals(java.lang.Object o)
equals
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object
public java.lang.String toString()
toString
in class java.lang.Object
public java.lang.String toString(long offset)