Class KafkaConsumerServiceDelegator

  • All Implemented Interfaces:, java.lang.AutoCloseable

    public class KafkaConsumerServiceDelegator
    extends AbstractKafkaConsumerService
    This delegator impl is used to distribute different partition requests into different consumer service. When is off, this class will always return the default consumer service. When the option is on, it will return the dedicated consumer service when the topic partition belongs to a Real-time topic and the corresponding store has active/active or write compute enabled. The reason to use dedicated consumer pool for leader replicas of active/active or write compute stores is that handling the writes before putting into the drainer queue is too expensive comparing to others.