public interface SdkProducerManager extends ProducerManager
| Modifier and Type | Method and Description | 
|---|---|
long | 
getProducerLastRecoveryAttemptTimestamp(int producerId)  | 
long | 
getProducerLastRecoveryMessageTimestamp(int producerId)  | 
void | 
internalSetProducerLastMessageTimestamp(int producerId,
                                       long lastMessageTimestamp)  | 
void | 
internalSetProducerLastRecoveryAttemptTimestamp(int producerId,
                                               long lastRecoveryAttemptTimestamp)  | 
void | 
internalSetProducerLastRecoveryMessageTimestamp(int producerId,
                                               long lastRecoveryMessageTimestamp)  | 
void | 
open()  | 
void | 
setLastAliveReceivedGenTimestamp(int producerId,
                                long aliveReceivedGenTimestamp)  | 
void | 
setLastProcessedMessageGenTimestamp(int producerId,
                                   long lastProcessedMessageGenTimestamp)  | 
void | 
setProducerDown(int producerId,
               boolean flaggedDown)  | 
void | 
setProducerRecoveryInfo(int producerId,
                       RecoveryInfo recoveryInfo)  | 
disableProducer, enableProducer, getActiveProducers, getAvailableProducers, getProducer, isProducerDown, isProducerEnabled, setProducerRecoveryFromTimestampvoid open()
void setProducerDown(int producerId,
                     boolean flaggedDown)
void internalSetProducerLastMessageTimestamp(int producerId,
                                             long lastMessageTimestamp)
void setLastProcessedMessageGenTimestamp(int producerId,
                                         long lastProcessedMessageGenTimestamp)
void setLastAliveReceivedGenTimestamp(int producerId,
                                      long aliveReceivedGenTimestamp)
void setProducerRecoveryInfo(int producerId,
                             RecoveryInfo recoveryInfo)
void internalSetProducerLastRecoveryMessageTimestamp(int producerId,
                                                     long lastRecoveryMessageTimestamp)
long getProducerLastRecoveryMessageTimestamp(int producerId)
void internalSetProducerLastRecoveryAttemptTimestamp(int producerId,
                                                     long lastRecoveryAttemptTimestamp)
long getProducerLastRecoveryAttemptTimestamp(int producerId)
Copyright © 2016–2025. All rights reserved.