apache-kafka - 将 SinkTask 的结果写入主题

Question

我正在为 kafka 开发一个接收器连接器，它从主题中读取事件，处理它们并将它们转换为 RedisDB 中的数据。我有兴趣将我的 redis 写入查询的结果生成到另一个主题，以便我可以从中消费它以用于其他 pourposes。因此，我在 SinkTask 中的 put() 方法中的最后一件事是“生成一些我已经在变量中获得的信息，作为 redis 查询的结果，到 kafka 主题”。我已经看到 Confluent Kafka Connect 有一个可以使用的 Connect Reporter 主题实现，这似乎是我正在寻找的，但我没有使用 confluent kafka，我也不会更改它，所以我不知道是否有在裸 apache kafka 中对此的任何干净解决方案或替代方案。

在我的每个接收器任务中添加一个 Kafka 生产者以使它们能够在 put() 中进行处理后生成一个 Kafka 主题会有什么问题吗？

非常感谢！

标签： apache-kafkaapache-kafka-connectkafka-producer-api