Interface SdkProducerManager

All Superinterfaces:
ProducerManager
All Known Implementing Classes:
ProducerManagerImpl

public interface SdkProducerManager extends ProducerManager
Created on 03/07/2017. // TODO @eti: Javadoc
  • Method Details

    • open

      void open()
    • setProducerDown

      void setProducerDown(int producerId, boolean flaggedDown)
    • internalSetProducerLastMessageTimestamp

      void internalSetProducerLastMessageTimestamp(int producerId, long lastMessageTimestamp)
    • setLastProcessedMessageGenTimestamp

      void setLastProcessedMessageGenTimestamp(int producerId, long lastProcessedMessageGenTimestamp)
    • setLastAliveReceivedGenTimestamp

      void setLastAliveReceivedGenTimestamp(int producerId, long aliveReceivedGenTimestamp)
    • setProducerRecoveryInfo

      void setProducerRecoveryInfo(int producerId, RecoveryInfo recoveryInfo)
    • internalSetProducerLastRecoveryMessageTimestamp

      void internalSetProducerLastRecoveryMessageTimestamp(int producerId, long lastRecoveryMessageTimestamp)
    • getProducerLastRecoveryMessageTimestamp

      long getProducerLastRecoveryMessageTimestamp(int producerId)
    • internalSetProducerLastRecoveryAttemptTimestamp

      void internalSetProducerLastRecoveryAttemptTimestamp(int producerId, long lastRecoveryAttemptTimestamp)
    • getProducerLastRecoveryAttemptTimestamp

      long getProducerLastRecoveryAttemptTimestamp(int producerId)