Skip to content

RecordCollectorImpl

RecordCollectorImpl is a RecordCollector.

Creating Instance

RecordCollectorImpl takes the following to be created:

RecordCollectorImpl is created when:

Sending Record

void send(
  String topic,
  K key,
  V value,
  Headers headers,
  Integer partition,
  Long timestamp,
  Serializer<K> keySerializer,
  Serializer<V> valueSerializer)
void send(
  String topic,
  K key,
  V value,
  Headers headers,
  Long timestamp,
  Serializer<K> keySerializer,
  Serializer<V> valueSerializer,
  StreamPartitioner<? super K, ? super V> partitioner)

send uses the given StreamPartitioner to determine the partition (of the record to be sent out) (if defined) and creates a ProducerRecord.

send requests the StreamsProducer to send the record and records the offset in the offsets registry.

send is part of the RecordCollector abstraction.

Back to top