Package com.linkedin.davinci.kafka.consumer

Class ActiveActiveProducerCallback

java.lang.Object

com.linkedin.davinci.kafka.consumer.LeaderProducerCallback

com.linkedin.davinci.kafka.consumer.ActiveActiveProducerCallback

All Implemented Interfaces:

PubSubProducerCallback, ChunkAwareCallback

public class ActiveActiveProducerCallback
extends LeaderProducerCallback

Field Summary

Fields inherited from class com.linkedin.davinci.kafka.consumer.LeaderProducerCallback

CHUNKED_VALUE_MANIFEST_SERIALIZER, chunkedRmdManifest, EMPTY_BYTE_BUFFER, ingestionTask, leaderProducedRecordContext, oldRmdManifest, oldValueManifest

Constructor Summary

Constructors

Constructor	Description
ActiveActiveProducerCallback(LeaderFollowerStoreIngestionTask ingestionTask, DefaultPubSubMessage sourceConsumerRecord, PartitionConsumptionState partitionConsumptionState, LeaderProducedRecordContext leaderProducedRecordContext, int partition, String kafkaUrl, long beforeProcessingRecordTimestamp)

Method Summary

Modifier and Type	Method	Description
protected Put	instantiateManifestPut()
protected Put	instantiateRmdChunkPut()
protected Put	instantiateValueChunkPut()

Methods inherited from class com.linkedin.davinci.kafka.consumer.LeaderProducerCallback

getIngestionTask, getPartitionConsumptionState, getSourceConsumerRecord, onCompletion, setChunkingInfo, setOnCompletionFunction

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ActiveActiveProducerCallback

public ActiveActiveProducerCallback(LeaderFollowerStoreIngestionTask ingestionTask,
 DefaultPubSubMessage sourceConsumerRecord,
 PartitionConsumptionState partitionConsumptionState,
 LeaderProducedRecordContext leaderProducedRecordContext,
 int partition,
 String kafkaUrl,
 long beforeProcessingRecordTimestamp)

Method Details

instantiateValueChunkPut

protected Put instantiateValueChunkPut()

Overrides:

instantiateValueChunkPut in class LeaderProducerCallback

instantiateRmdChunkPut

protected Put instantiateRmdChunkPut()

Overrides:

instantiateRmdChunkPut in class LeaderProducerCallback

instantiateManifestPut

protected Put instantiateManifestPut()

Overrides:

instantiateManifestPut in class LeaderProducerCallback