Sunday, May 7, 2023

Kafka Connect SinkTaskContext Arayüzü

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);


No comments:

Post a Comment

Consumer Failover Across Data Centers

Active-Passive Consumption Across Data Centers Açıklaması şöyle In Kafka, a common consumption pattern for multi-data center setups in...