Class OffsetCommitAckEvent
- java.lang.Object
-
- org.apache.flink.cdc.connectors.postgres.source.events.OffsetCommitAckEvent
-
- All Implemented Interfaces:
Serializable,org.apache.flink.api.connector.source.SourceEvent
public class OffsetCommitAckEvent extends Object implements org.apache.flink.api.connector.source.SourceEvent
TheSourceEventthatPostgresSourceReaderbroadcasts toPostgresSourceEnumeratorto tell the enumerator that offset commit is already suspend. Then the enumerator can assign new added table's snapshot splits.- See Also:
- Serialized Form