lib/poseidon/consumer_group.rb
# Commits the latest offset for a partition
# @param [Integer] partition
# @param [Integer] offset
Commits the latest offset for a partition
Commits the latest offset for a partition
def commit(partition, offset)
    zk.set offset_path(partition), offset.to_s
  rescue ZK::Exceptions::NoNode
    zk.create offset_path(partition), offset.to_s, ignore: :node_exists
  end
def commit ( partition , offset ) zk . set offset_path ( partition ) , offset . to_s rescue ZK :: Exceptions :: NoNode zk . create offset_path ( partition ) , offset . to_s , ignore : :node_exists end
Commits the latest offset for a partition
Commits the latest offset for a partition
partition
<not_specific>
offset
<not_specific>
<not_specific>
None