public class OffsetTracker
extends java.lang.Object
| Constructor and Description |
|---|
OffsetTracker(java.lang.String provider,
java.lang.String topic,
java.sql.Connection conn) |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
java.lang.Long |
getOffset(int tpart) |
void |
setOffset(java.lang.Long offset,
int tpart) |
public OffsetTracker(java.lang.String provider,
java.lang.String topic,
java.sql.Connection conn)
throws java.sql.SQLException,
MXException
java.sql.SQLExceptionMXExceptionpublic java.lang.Long getOffset(int tpart)
throws java.sql.SQLException
java.sql.SQLExceptionpublic void setOffset(java.lang.Long offset,
int tpart)
throws java.sql.SQLException,
MXException
java.sql.SQLExceptionMXExceptionpublic void close()