【发布时间】：2017-03-27 18:18:53
【问题描述】：
我正在开发一个订阅主题、转换消息、将转换后的消息推送回另一个主题的 Kafka-Connector。
到目前为止，我将其实现为 SinkTask 类，每个任务都执行 ETL，实例化发布者对象，将消息写回另一个主题。
有没有更简洁的方法来实现它？我相信这是一个常见的用例，即连接器既是接收器也是源。
【问题讨论】：
标签： apache-kafka apache-kafka-connect
【发布时间】：2017-03-27 18:18:53
【问题描述】：
这不是 Kafka Connect 的基本用例。如果您已经在使用 Kafka 0.10.x，那么新的 Kafka Streams API 就是专门为这类事情创建的。
【讨论】：
-
谢谢。我坚持使用较旧的 Kafka，所以我没有注意到 Kafka Streams 解决了这一需求。