postgres-cdc-flink:使用Debezium流式传输PostgreSQL CDC，并使用Flink使用状态流进行充...
需积分: 50 40 浏览量
2021-04-10
00:53:17
上传
评论 1
收藏 67KB ZIP 举报
postgres-cdc-flink-main.zip （45个子文件） 
postgres-cdc-flink-main 
.gitignore 4KB .project 939B README.md 2KB pom.xml 7KB .github workflows maven.yml 715B .vscode launch.json 826B settings.json 2B LICENSE 11KB sql tables.sql 2KB src test java dev ramottamado java flink TransactionsEnrichmentStreamingJobIntegrationTest.java 6KB functions DestinationAccountKeySelectorTest.java 2KB helper TestSourceFunction.java 2KB TestTimestampAssigner.java 1KB EnrichTransactionsWithCustomersJoinFunctionTest.java 5KB EnrichEnrichedTransactionsWithCustomersJoinFunctionTest.java 5KB EnrichedTransactionsToStringMapFunctionTest.java 2KB EnvelopeParserMapFunctionTest.java 3KB util jackson helper ClassWithCustomSerDe.java 3KB deserializer MicroTimestampDeserializerTest.java 3KB serializer TimestampSerializerTest.java 3KB serialization DebeziumJSONEnvelopeDeserializationSchemaTest.java 5KB JSONValueDeserializationSchemaTest.java 3KB main resources log4j2.properties 1KB java dev ramottamado java flink functions EnrichTransactionsWithCustomersJoinFunction.java 5KB DestinationAccountKeySelector.java 1KB EnrichEnrichedTransactionsWithCustomersJoinFunction.java 4KB EnrichedTransactionsToStringMapFunction.java 2KB EnvelopeParserMapFunction.java 2KB api schema ClassWithTimestamp.java 1KB KafkaTransactionsEnrichmentStreamingJob.java 7KB config ParameterConfig.java 2KB schema TransactionsWithTimestamp.java 2KB EnrichedTransactions.java 5KB EnrichedTransactionsWithTimestamp.java 2KB Transactions.java 4KB Customers.java 3KB util ParameterUtils.java 2KB jackson deserializer MicroTimestampDeserializer.java 2KB serializer TimestampSerializer.java 2KB kafka KafkaProperties.java 2KB serialization DebeziumJSONEnvelopeDeserializationSchema.java 2KB EnrichedTransactionsKafkaSerializationSchema.java 2KB JSONValueDeserializationSchema.java 2KB AbstractTransactionsEnrichmentStreamingJob.java 5KB .classpath 11KB资源评论
