pause.java

// get all assigned partitions for the consumer
Set<TopicPartition> assignedPartitions = consumer.assignment();

// pause all assigned partitions
Set<TopicPartition> pausedPartitions = consumer.pause(assignedPartitions);

// resume all paused partitions 
consumer.resume(consumer.paused());

// you could also resume the consumer.assignment() since everything is paused
consumer.resume(consumer.assignment());