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
java.sql.SQLException
public java.lang.Long getOffset(int tpart) throws java.sql.SQLException
java.sql.SQLException
public void setOffset(java.lang.Long offset, int tpart) throws java.sql.SQLException, MXException
java.sql.SQLException
MXException
public void close()