Sunday, May 7, 2023

Kafka Connect SinkTask Sınıfı

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


at

No comments:

Post a Comment

Subscribe to: Post Comments (Atom)

kafka-consumer-groups.sh komutu

Giriş Bir topic'i dinleyen consumer'ları gösterir. Aynı topic'i dinleyen consumer group'ları olabilir. Her topic farklı part...