IGNITE-14362: CDC Ignite to Kafka extension (#49)
authorNikolay <nizhikov@apache.org>
Wed, 30 Jun 2021 16:13:26 +0000 (19:13 +0300)
committerGitHub <noreply@github.com>
Wed, 30 Jun 2021 16:13:26 +0000 (19:13 +0300)
commitc478ce1c80d0a24f052a2ce26c407987cc046519
tree30bd35103177bac89a54a48374879572c4a41e12
parentfc93b712c2e2c6e74189060b6d8e65cd345600c2
IGNITE-14362: CDC Ignite to Kafka extension (#49)
36 files changed:
.gitignore
modules/cdc-ext/assembly/cdc-ext.xml [new file with mode: 0644]
modules/cdc-ext/bin/kafka-to-ignite.sh [new file with mode: 0755]
modules/cdc-ext/modules/core/src/test/config/log4j-test.xml [new file with mode: 0644]
modules/cdc-ext/modules/core/src/test/config/tests.properties [new file with mode: 0644]
modules/cdc-ext/pom.xml [new file with mode: 0644]
modules/cdc-ext/src/main/java/org/apache/ignite/cdc/CdcEventsApplier.java [new file with mode: 0644]
modules/cdc-ext/src/main/java/org/apache/ignite/cdc/IgniteToIgniteCdcStreamer.java [new file with mode: 0644]
modules/cdc-ext/src/main/java/org/apache/ignite/cdc/conflictresolve/CacheConflictResolutionManagerImpl.java [new file with mode: 0644]
modules/cdc-ext/src/main/java/org/apache/ignite/cdc/conflictresolve/CacheVersionConflictResolverCachePluginProvider.java [new file with mode: 0644]
modules/cdc-ext/src/main/java/org/apache/ignite/cdc/conflictresolve/CacheVersionConflictResolverImpl.java [new file with mode: 0644]
modules/cdc-ext/src/main/java/org/apache/ignite/cdc/conflictresolve/CacheVersionConflictResolverPluginProvider.java [new file with mode: 0644]
modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/IgniteToKafkaCdcStreamer.java [new file with mode: 0644]
modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/KafkaToIgniteCdcStreamer.java [new file with mode: 0644]
modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/KafkaToIgniteCdcStreamerApplier.java [new file with mode: 0644]
modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/KafkaToIgniteCdcStreamerConfiguration.java [new file with mode: 0644]
modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/KafkaToIgniteCommandLineStartup.java [new file with mode: 0644]
modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/KafkaToIgniteLoader.java [new file with mode: 0644]
modules/cdc-ext/src/test/java/org/apache/ignite/cdc/AbstractReplicationTest.java [new file with mode: 0644]
modules/cdc-ext/src/test/java/org/apache/ignite/cdc/CacheConflictOperationsTest.java [new file with mode: 0644]
modules/cdc-ext/src/test/java/org/apache/ignite/cdc/CacheConflictOperationsWithFieldTest.java [new file with mode: 0644]
modules/cdc-ext/src/test/java/org/apache/ignite/cdc/CdcIgniteToIgniteReplicationTest.java [new file with mode: 0644]
modules/cdc-ext/src/test/java/org/apache/ignite/cdc/ConflictResolvableTestData.java [new file with mode: 0644]
modules/cdc-ext/src/test/java/org/apache/ignite/cdc/IgniteCdcTestSuite.java [new file with mode: 0644]
modules/cdc-ext/src/test/java/org/apache/ignite/cdc/kafka/CdcKafkaReplicationAppsTest.java [new file with mode: 0644]
modules/cdc-ext/src/test/java/org/apache/ignite/cdc/kafka/CdcKafkaReplicationTest.java [new file with mode: 0644]
modules/cdc-ext/src/test/java/org/apache/ignite/cdc/kafka/KafkaToIgniteLoaderTest.java [new file with mode: 0644]
modules/cdc-ext/src/test/resources/loader/kafka-to-ignite-correct.xml [new file with mode: 0644]
modules/cdc-ext/src/test/resources/loader/kafka-to-ignite-double-ignite-cfg.xml [new file with mode: 0644]
modules/cdc-ext/src/test/resources/loader/kafka-to-ignite-without-kafka-properties.xml [new file with mode: 0644]
modules/cdc-ext/src/test/resources/loader/kafka.properties [new file with mode: 0644]
modules/cdc-ext/src/test/resources/replication/ignite-to-kafka.xml [new file with mode: 0644]
modules/cdc-ext/src/test/resources/replication/kafka-to-ignite.xml [new file with mode: 0644]
modules/performance-statistics-ext/pom.xml
parent/pom.xml
pom.xml