public interface RecordCollector
Modifier and Type | Interface and Description |
---|---|
static interface |
RecordCollector.Supplier
A supplier of a
RecordCollectorImpl instance. |
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) |
<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)
void init(org.apache.kafka.clients.producer.Producer<byte[],byte[]> producer)
producer
- the producer that should be used by this collectorvoid flush()
Producer
.void close()
Producer
.java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long> offsets()
Producer
.