时间戳

首页 > 解决方案 > 接收器连接器暂停后，Put 方法仍在处理

java - 接收器连接器暂停后，Put 方法仍在处理

问题描述

我们正在编写一个接收器连接器，并使用 Kafka connect-api 版本 2.5.1 和 confluent 5.5。我们观察到，即使连接器处于暂停状态（连接器和任务都处于暂停状态），但 put 方法仍然没有暂停并继续运行。我们放置的测试记录器不断出现在日志中。

我试图了解我们是否在这里遗漏了任何东西，或者这是设计使然。

为了测试流程，我们保持 put 方法非常基本。

@Override
public void put(Collection<SinkRecord> records) {
    recordCounter = 0;
    if (!records.isEmpty()) {
        recordCounter ++;
    }
    logger.info("Put method :::: recordCounter :: " + recordCounter);
}

标签： javaapache-kafkaapache-kafka-connect

解决方案

推荐阅读