如何设计卡夫卡连接即水槽以及来源

Question

我正在开发一个卡夫卡连接器，订阅一个主题，转换的消息，推动转化的消息回到另一个话题。

到目前为止，我将它作为SinkTask类实现，每个任务执行ETL，实例化发布程序对象，将消息写回另一个主题。

有没有实现它一个更清洁的方式？我相信这是一个常见的用例，连接器是一个接收器以及源代码。

Answer 1

这不是基本的用例卡夫卡连接。如果您已经使用Kafka 0.10.x，则新的Kafka Streams API就是为这类事情创建的。