public static class CdcCommonProperties.Offset extends Object
Modifier and Type | Class and Description |
---|---|
static class |
CdcCommonProperties.Offset.OffsetPolicy |
Constructor and Description |
---|
Offset() |
Modifier and Type | Method and Description |
---|---|
Duration |
getCommitTimeout() |
Duration |
getFlushInterval() |
CdcCommonProperties.Offset.OffsetPolicy |
getPolicy() |
CdcCommonProperties.OffsetStorageType |
getStorage() |
void |
setCommitTimeout(Duration commitTimeout) |
void |
setFlushInterval(Duration flushInterval) |
void |
setPolicy(CdcCommonProperties.Offset.OffsetPolicy policy) |
void |
setStorage(CdcCommonProperties.OffsetStorageType storage) |
public Duration getFlushInterval()
public void setFlushInterval(Duration flushInterval)
public Duration getCommitTimeout()
public void setCommitTimeout(Duration commitTimeout)
public CdcCommonProperties.Offset.OffsetPolicy getPolicy()
public void setPolicy(CdcCommonProperties.Offset.OffsetPolicy policy)
public CdcCommonProperties.OffsetStorageType getStorage()
public void setStorage(CdcCommonProperties.OffsetStorageType storage)
Copyright © 2022. All rights reserved.