Class AbstractStoreBufferService

    • Constructor Detail

      • AbstractStoreBufferService

        public AbstractStoreBufferService()
    • Method Detail

      • drainBufferedRecordsFromTopicPartition

        public abstract void drainBufferedRecordsFromTopicPartition​(PubSubTopicPartition topicPartition)
                                                             throws java.lang.InterruptedException
        This method will wait for all the messages to be processed (persisted to disk) that are already queued up to drainer till now.
        Throws:
        java.lang.InterruptedException
      • getDrainerCount

        public abstract int getDrainerCount()
      • getDrainerQueueMemoryUsage

        public abstract long getDrainerQueueMemoryUsage​(int index)
      • getTotalMemoryUsage

        public abstract long getTotalMemoryUsage()
      • getTotalRemainingMemory

        public abstract long getTotalRemainingMemory()
      • getMaxMemoryUsagePerDrainer

        public abstract long getMaxMemoryUsagePerDrainer()
      • getMinMemoryUsagePerDrainer

        public abstract long getMinMemoryUsagePerDrainer()