Giriş
Şu satırı dahil ederiz. Soyut bir sınıftır
import org.apache.kafka.connect.sink.SinkTaskContext;
timeout metodu - (long timeoutMs)
İmzası şöyle
void timeout(long timeoutMs);
import org.apache.kafka.connect.sink.SinkTaskContext;
void timeout(long timeoutMs);
Giriş Bir topic'i dinleyen consumer'ları gösterir. Aynı topic'i dinleyen consumer group'ları olabilir. Her topic farklı part...
No comments:
Post a Comment