jgillis01

Kafka 0.11.0.0 (Confluent 3.3.0) added support to manipulate offsets for a consumer group via cli kafka-consumer-groups command.

1. List the topics to which the group is subscribed

kafka-consumer-groups --bootstrap-server <kafkahost:port> --group <group_id> --describe

Note the values under "CURRENT-OFFSET" and "LOG-END-OFFSET". "CURRENT-OFFSET" is the offset where this consumer group is currently at in each of the partitions.

2. Reset the consumer offset for a topic (preview)

jgillis01

Keybase proof

I hereby claim:

• I am jgillis01 on github.
• I am jeffreygillis1 (https://keybase.io/jeffreygillis1) on keybase.
• I have a public key whose fingerprint is 232D FA74 0FD7 F614 4603 B23F 0E5D CA0E ACF3 DAE5

To claim this, I am signing this object:

jgillis01

defmodule Cryptograms do

  def encode(text) do
    map = map
    text
    |> clean_input
    |> Enum.map(&find_match(&1,map))
    |> to_string
  end

jgillis01

require 'serverspec'

include Serverspec::Helper::Exec
include Serverspec::Helper::DetectOS

RSpec.configure do |c|
  c.before :all do
    c.path = '/sbin:/usr/sbin'
  end
end