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, setProducerRecoveryFromTimestamp
void 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.