| Package | Description |
|---|---|
| com.ververica.cdc.debezium | |
| com.ververica.cdc.debezium.internal | |
| com.ververica.cdc.debezium.utils |
| Class and Description |
|---|
| DebeziumOffset
The state that the Flink Debezium Consumer holds for each instance.
|
| Class and Description |
|---|
| DebeziumOffset
The state that the Flink Debezium Consumer holds for each instance.
|
| DebeziumOffsetSerializer
Serializer implementation for a
DebeziumOffset. |
| Handover
The Handover is a utility to hand over data (a buffer of records) and exception from a
producer thread to a consumer thread.
|
| SchemaRecord
The Record represents a schema change event, it contains either one
HistoryRecord or
TableChanges.TableChange. |
| Class and Description |
|---|
| SchemaRecord
The Record represents a schema change event, it contains either one
HistoryRecord or
TableChanges.TableChange. |
Copyright © 2022 The Apache Software Foundation. All rights reserved.