测试 Spring Cloud Stream 应用 - 第 2 部分
这是测试 Stream 应用的第 2 部分。在第 1 部分中,我们实现并测试了我们示例 couchbase-sink 应用所需的核心功能。函数级别的测试涵盖了预期的成功和错误场景,并依赖于 Testcontainers 来配置 Couchbase 集群。本文假设您已阅读第 1 部分,并接着上一部分的内容。
Couchbase Sink
在第 1 部分中,我们验证了我们为 upserting 数据到 Couchbase 编写的函数按预期工作。现在我们可以使用这个函数,它被暴露为一个 java.util.Consumer
,来实现一个 sink,以便在用…构建的数据管道中使用。