Package org.apache.flink.cdc.connectors.postgres.source.events
-
Class Summary Class Description OffsetCommitAckEvent TheSourceEventthatPostgresSourceReaderbroadcasts toPostgresSourceEnumeratorto tell the enumerator that offset commit is already suspend.OffsetCommitEvent TheSourceEventthatPostgresSourceEnumeratorsend toPostgresSourceReader, which includes current assign status.