apache-kafka - 如何摆脱 Kafka 中的负面消费者滞后

Question

最近我监控我的集群，我看到了负面的消费者滞后：

这种负面滞后会影响集群上的接收器连接器，我在Kafka-Connect上收到此错误：

Mar 25 15:56:30 Master1 connect-distributed[14530]: [2020-03-25 15:56:30,910] WARN WorkerSinkTask{id=hdfs-1} Ignoring invalid task provided offset mongodb.db.collection-1/OffsetAndMetadata{offset=84, leaderEpoch=null, metadata=''} -- not yet consumed, taskOffset=84 currentOffset=7 (org.apache.kafka.connect.runtime.WorkerSinkTask:417)

标签： apache-kafkajmxapache-kafka-connect