Package com.linkedin.davinci.kafka.consumer

Interface TopicPartitionConsumerFunction

public interface TopicPartitionConsumerFunction

Method Summary

Modifier and Type	Method	Description
boolean	execute(String topic, int partition)	Apply a pause/resume action on the given topic-partition.

Method Details

execute

boolean execute(String topic,
 int partition)

Apply a pause/resume action on the given topic-partition.

Returns:

true if the action was applied to the underlying consumer; false if the implementation chose to no-op (e.g. because a higher-priority pause source — such as a store-level IngestionPauseMode — already owns the consumer state). Callers that maintain their own bookkeeping should gate updates on this value to avoid desynchronizing from real consumer state.