Kafka Connect SourceTask Sınıfı - Poll İşlemini Yapar

Giriş

Şu satırı dahil ederiz. Soyut bir sınıftır

import org.apache.kafka.connect.source.SourceTask;

poll metodu

İmzası şöyle. Ya null döner, ya da bir List döner. SourceRecord yazısına bakabilirsiniz.

public abstract List<SourceRecord> poll() throws InterruptedException;

Örnek

Şöyle yaparız

import org.apache.kafka.connect.source.SourceRecord;

List<SourceRecord> list = task.poll();