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, PubSubMessage<KafkaKey,KafkaMessageEnvelope,java.lang.Long> sourceConsumerRecord, PartitionConsumptionState partitionConsumptionState, LeaderProducedRecordContext leaderProducedRecordContext, int subPartition, java.lang.String kafkaUrl, long beforeProcessingRecordTimestamp)

Method Summary

Modifier and Type	Method	Description
protected Put	instantiateManifestPut()
protected Put	instantiateRmdChunkPut()
protected Put	instantiateValueChunkPut()
void	onCompletion(PubSubProduceResult produceResult, java.lang.Exception exception)	exception will be null if request was completed without an error.
void	setOnCompletionFunction(java.lang.Runnable onCompletionFunction)

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

getIngestionTask, getPartitionConsumptionState, getSourceConsumerRecord, setChunkingInfo

Methods inherited from class java.lang.Object

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

Constructor Detail

ActiveActiveProducerCallback

public ActiveActiveProducerCallback(LeaderFollowerStoreIngestionTask ingestionTask,
                                    PubSubMessage<KafkaKey,KafkaMessageEnvelope,java.lang.Long> sourceConsumerRecord,
                                    PartitionConsumptionState partitionConsumptionState,
                                    LeaderProducedRecordContext leaderProducedRecordContext,
                                    int subPartition,
                                    java.lang.String kafkaUrl,
                                    long beforeProcessingRecordTimestamp)

Method Detail

onCompletion

public void onCompletion(PubSubProduceResult produceResult,
                         java.lang.Exception exception)

Description copied from interface: PubSubProducerCallback

exception will be null if request was completed without an error.

Specified by:

onCompletion in interface PubSubProducerCallback

Overrides:

onCompletion in class LeaderProducerCallback

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

setOnCompletionFunction

public void setOnCompletionFunction(java.lang.Runnable onCompletionFunction)