Class: ZookeeperConsumerConnector

Inherits:

Object

Object
ZookeeperConsumerConnector

Defined in:: lib/jruby-kafka/ext.rb

Instance Method Summary collapse

#commitOffset(topic, partition, offset) ⇒ Object

Instance Method Details

#commitOffset(topic, partition, offset) ⇒ `Object`



8
9
10

# File 'lib/jruby-kafka/ext.rb', line 8

def commitOffset(topic, partition, offset)
  self.underlying.commitOffsetToZooKeeper(TopicAndPartition.new(topic, partition), offset)
end