Contents

require 'java'
java_import "kafka.common.TopicAndPartition"
java_import "kafka.javaapi.consumer.ZookeeperConsumerConnector"

class ZookeeperConsumerConnector
  field_reader :underlying

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

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
sorceror_jruby-kafka-2.2.0-java	lib/jruby-kafka/ext.rb
sorceror_jruby-kafka-2.1.0-java	lib/jruby-kafka/ext.rb
sorceror_jruby-kafka-2.0.1-java	lib/jruby-kafka/ext.rb
sorceror_jruby-kafka-2.0.0-java	lib/jruby-kafka/ext.rb