编写自定义水槽NG源/水槽的最佳方式

Question

我正在编写自定义水槽源和水槽，目前我没有看到 重新使用现有水槽代码的最佳方式。例如，我无法 扩展AvroSource类和轻松定制一些功能，而无需 必须复制/粘贴大量现有代码。它是打算如此 或我在这里做错了什么？

Answer 1

如果您想要接受Avro邮件的来源，您只需要自定义AvroSource。这将是一个令人惊讶的原因，编写一个自定义源和接收器。

要编写自定义接收器，请按照custom sink docs。自定义源代码位于相同的文档中。

顺便说一句，为什么你需要一个自定义的源和接收器？

最后，1.4.0刚刚发布 - 如果可能的话，您应该使用它。