class Kafka::Client

def partitions_for(topic)

Returns:
  • (Integer) - the number of partitions in the topic.

Parameters:
  • topic (String) -- 
def partitions_for(topic)
  @cluster.partitions_for(topic).count
end