Kafka Connect HDFS 接收器问题

Kafka Connect HDFS Sink Issue

我正在尝试使用带有 HDFS 接收器连接器的 Kafka-Connect 来传输数据。 Standalone 和 Distributed 模式都很好 运行 但它只写入 HDFS 一次(基于 flush-size)并且以后不会流式传输。如果我遗漏了什么,请帮忙。

融合 2.0.0 & 卡夫卡 0.9.0

我遇到这个问题很久了 back.Just 检查下面的参数是否丢失

Connect-hdfs-sink 属性

"logs.dir":"/hdfs_directory/data/log"

"request.timeout.ms":"310000"

"offset.flush.interval.ms":"5000"

"heartbeat.interval.ms":"60000"

"session.timeout.ms":"300000

"max.poll.records":"100"