RecordCollectorImpl¶

RecordCollectorImpl is a RecordCollector.

Creating Instance¶

RecordCollectorImpl takes the following to be created:

• LogContext
• TaskId
• StreamsProducer
• ProductionExceptionHandler
• StreamsMetricsImpl

RecordCollectorImpl is created when:

• ActiveTaskCreator is requested to createActiveTask
• TopologyTestDriver is requested to setupTask

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.