Kafka Connect ConnectRecord Sınıfı - Soyut Sınıf

Giriş

Şu satırı dahil ederiz

import org.apache.kafka.connect.connector.ConnectRecord;

Bir connector tarafından işlenen kayıdı temsil eder. Açıklaması şöyle. SourceTask poll() işlemini yapar. SinkTask put() işlemini yapar

ConnectRecord objects are passed between the connector's SourceTask and SinkTask implementations. SourceTask implementations use ConnectRecord objects to read records from an external system and write them to Kafka, while SinkTask implementations use ConnectRecord objects to read records from Kafka and write them to an external system.

Kodu şöyle.

public abstract class ConnectRecord<R extends ConnectRecord<R>> {
  private final String topic;
  private final Integer kafkaPartition;
  private final Schema keySchema;
  private final Object key;
  private final Schema valueSchema;
  private final Object value;
  private final Long timestamp;
  private final Headers headers;
  ...
}