public class RecordCollectorImpl extends java.lang.Object implements RecordCollector
RecordCollector.Supplier
Constructor and Description |
---|
RecordCollectorImpl(java.lang.String streamTaskId,
org.apache.kafka.common.utils.LogContext logContext,
ProductionExceptionHandler productionExceptionHandler,
org.apache.kafka.common.metrics.Sensor skippedRecordsSensor) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Close the internal
Producer . |
void |
flush()
Flush the internal
Producer . |
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 internal
Producer . |
<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) |
<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) |
public RecordCollectorImpl(java.lang.String streamTaskId, org.apache.kafka.common.utils.LogContext logContext, ProductionExceptionHandler productionExceptionHandler, org.apache.kafka.common.metrics.Sensor skippedRecordsSensor)
public void init(org.apache.kafka.clients.producer.Producer<byte[],byte[]> producer)
RecordCollector
init
in interface RecordCollector
producer
- the producer that should be used by this collectorpublic <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)
send
in interface RecordCollector
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)
send
in interface RecordCollector
public void flush()
RecordCollector
Producer
.flush
in interface RecordCollector
public void close()
RecordCollector
Producer
.close
in interface RecordCollector
public java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long> offsets()
RecordCollector
Producer
.offsets
in interface RecordCollector