我正在编写自定义水槽源和接收器，目前我没有看到重用现有水槽-ng 代码的最佳方法。例如，我无法扩展 AvroSource 类并轻松自定义某些功能，而无需复制/粘贴大量现有代码。是打算这样做还是我在这里做错了什么？
问问题
5712 次
如果您想要一个接受 Avro 消息的源，您只需要自定义 AvroSource。这将是编写自定义源和接收器的一个令人惊讶的原因。
要编写自定义接收器，请遵循自定义接收器文档。自定义源在同一文档中。
顺便说一句，为什么需要自定义源和接收器？
最后，1.4.0 刚刚发布 - 如果可能，您应该使用它。