class Karafka::Connection::Client

def pause(topic, partition)

Parameters:
  • partition (Integer) -- number partition that we want to pause
  • topic (String) -- topic that we want to pause 
def pause(topic, partition)
  kafka_consumer.pause(*ApiAdapter.pause(topic, partition, consumer_group))
end