如何将kafka写入kafka sink连接器

Question

我正在尝试使用 kafka 镜像。我发现了这个开源 [Comcast]：https://github.com/Comcast/MirrorTool-for-Kafka-Connect，它在从源 kafka 主题检索数据并将其写入目标 kafka 主题时成功运行。现在我需要从目标 kafka 主题下沉并将其写入源 kafka。我该怎么做，请建议参考。

我写了 kafkaSinkTask 文件。在 put 方法中，我能够从目标 kafka 获取主题。所以我不知道如何将这个主题写到 source kfafa

    @Override
    public void put(Collection<SinkRecord> records) {
        if (records.isEmpty()) {
              return;
            }
            final SinkRecord first = records.iterator().next();
            final int recordsCount = records.size();
            logger.info(
                "Received {} records. First record kafka coordinates:({}-{}-{}).
                + "database...",
                recordsCount, first.topic(), first.kafkaPartition(), first.kafkaOffset()
            );  
    }

Answer 1

现在我需要从目标 kafka 主题下沉并将其写入源 kafka

你不能只翻转配置文件中的源服务器和目标服务器吗？ Connect 通常应该从远程集群消费并生产到本地集群（给定两个数据中心或地理上分离的网络），并将消费的偏移量存储在 Connect offsets 主题中的目的地，因此它是一个源连接器。

您也可以尝试 MirrorMaker 2.0 - https://cwiki.apache.org/confluence/display/KAFKA/KIP-382%3A+MirrorMaker+2.0