Giriş
Şu satırı dahil ederiz. Soyut bir sınıftır
import org.apache.kafka.connect.sink.SinkTask;
put metodu
İmzası şöyle
public abstract void put(Collection<SinkRecord> records);
Subscribe to:
Post Comments (Atom)
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...
No comments:
Post a Comment