Class RecordCollectorImpl
- java.lang.Object
-
- org.apache.kafka.streams.processor.internals.RecordCollectorImpl
-
- All Implemented Interfaces:
RecordCollector
public class RecordCollectorImpl extends java.lang.Object implements RecordCollector
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.kafka.streams.processor.internals.RecordCollector
RecordCollector.Supplier
-
-
Constructor Summary
Constructors Constructor Description RecordCollectorImpl(java.lang.String streamTaskId, org.apache.kafka.common.utils.LogContext logContext, ProductionExceptionHandler productionExceptionHandler, org.apache.kafka.common.metrics.Sensor skippedRecordsSensor)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
Close the internalProducer
.void
flush()
Flush the internalProducer
.void
init(org.apache.kafka.clients.producer.Producer<byte[],byte[]> producer)
Initialize the collector with a producer.java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long>
offsets()
The last acked offsets from the internalProducer
.<K,V>
voidsend(java.lang.String topic, K key, V value, org.apache.kafka.common.header.Headers headers, java.lang.Integer partition, java.lang.Long timestamp, org.apache.kafka.common.serialization.Serializer<K> keySerializer, org.apache.kafka.common.serialization.Serializer<V> valueSerializer)
<K,V>
voidsend(java.lang.String topic, K key, V value, org.apache.kafka.common.header.Headers headers, java.lang.Long timestamp, org.apache.kafka.common.serialization.Serializer<K> keySerializer, org.apache.kafka.common.serialization.Serializer<V> valueSerializer, StreamPartitioner<? super K,? super V> partitioner)
-
-
-
Constructor Detail
-
RecordCollectorImpl
public RecordCollectorImpl(java.lang.String streamTaskId, org.apache.kafka.common.utils.LogContext logContext, ProductionExceptionHandler productionExceptionHandler, org.apache.kafka.common.metrics.Sensor skippedRecordsSensor)
-
-
Method Detail
-
init
public void init(org.apache.kafka.clients.producer.Producer<byte[],byte[]> producer)
Description copied from interface:RecordCollector
Initialize the collector with a producer.- Specified by:
init
in interfaceRecordCollector
- Parameters:
producer
- the producer that should be used by this collector
-
send
public <K,V> void send(java.lang.String topic, K key, V value, org.apache.kafka.common.header.Headers headers, java.lang.Long timestamp, org.apache.kafka.common.serialization.Serializer<K> keySerializer, org.apache.kafka.common.serialization.Serializer<V> valueSerializer, StreamPartitioner<? super K,? super V> partitioner)
- Specified by:
send
in interfaceRecordCollector
-
send
public <K,V> void send(java.lang.String topic, K key, V value, org.apache.kafka.common.header.Headers headers, java.lang.Integer partition, java.lang.Long timestamp, org.apache.kafka.common.serialization.Serializer<K> keySerializer, org.apache.kafka.common.serialization.Serializer<V> valueSerializer)
- Specified by:
send
in interfaceRecordCollector
-
flush
public void flush()
Description copied from interface:RecordCollector
Flush the internalProducer
.- Specified by:
flush
in interfaceRecordCollector
-
close
public void close()
Description copied from interface:RecordCollector
Close the internalProducer
.- Specified by:
close
in interfaceRecordCollector
-
offsets
public java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long> offsets()
Description copied from interface:RecordCollector
The last acked offsets from the internalProducer
.- Specified by:
offsets
in interfaceRecordCollector
- Returns:
- the map from TopicPartition to offset
-
-