Kafka Connect SourceRecord Sınıfı

Giriş

Şu satırı dahil ederiz

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

SourceTask nesnesinin poll() çağrısı bize bu nesnenin listesini döndürür

SourceRecord kalıtımı şöyle

public class SourceRecord extends ConnectRecord<SourceRecord>

sourcePartition metodu

Örnek

Şöyle yaparız

Map<Map<String, ?>, Map<String, ?>> partitionsToOffset = new ConcurrentHashMap<>();

SourceRecord rec = ...;
partitionsToOffset.put(rec.sourcePartition(), rec.sourceOffset());

value metodu

Örnek

Şöyle yaparız

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

String convertToString(SourceRecord rec) {
  return Values.convertToString(rec.valueSchema(), rec.value());
}