952340286e
DBZ-4027 Add an Incremental snapshot test with kafka signaling DBZ-4027 Add an Incremental snapshot test with kafka signaling DBZ-4027 Add an Incremental snapshot test with kafka signaling DBZ-4027 Code style DBZ-4027 Make SignalPayload more generic and extensible DBZ-4027 Rename DatabaseSignalChannel to SourceSignalChannel DBZ-4027 Improve logging DBZ-4027 Moved SPI file definition to debezium-core DBZ-4027 Move SignalProcessor synchronization point to be processed only when a signal cdc event arrives. DBZ-4027 Add EventDispatcher constructor without signalProcessor for spanner connector DBZ-4027 Fix NPE DBZ-4027 Fix NPE DBZ-4027 Formatting DBZ-4027 Correctly manage signal on not supported connector DBZ-4027 Use the correct MongoDbOffset DBZ-4027 Correctly initialize offset for Oracle and SqlServer connectors DBZ-4027 Register SPI implementations DBZ-4027 Improve SignalProcessor instantiation DBZ-4027 Pass source info in case of SchemaChanges action DBZ-4027 Manage close event in a synchronous way DBZ-4027 Correctly init offset context also in case of snapshot mode 'never' DBZ-4027 Fix MySqlMetricsIT test DBZ-4027 Move KafkaSignalChannel to core DBZ-4027 Move KafkaSignalChannel to core DBZ-4027 Set pass offset context after initial snapshot to SignalProcessor DBZ-4027 Pass OffsetContext to signal processor DBZ-4027 Pass CommonConnectorConfig to SignalChannelReader init method DBZ-4027 Move Incremental snapshot window actions to dedicated package DBZ-4027 Align SignalsIT test with new code DBZ-4027 Fix SignalsIT test DBZ-4027 Fix SignalProcessor scheduling DBZ-4027 Moved DatabaseSignalChannel and SignalChannelReader to dedicated package DBZ-4027 Start SignalProcessor from ChangeEventSourceCoordinator DBZ-4027 Create SignalProcessor and renamed Signal to DatabaseSignalChannel DBZ-4027 Initial refactoring of signal feature |
||
|---|---|---|
| .. | ||
| src | ||
| pom.xml | ||