Luke Thomas luk3thomas

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

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.

Reset the consumer offset for a topic (preview)

This config wrapper is based on the one I originally saw in https://gist.github.com/bitwalker/a4f73b33aea43951fe19b242d06da7b9.

$ ruby server.rb

Setup

npm install --save-dev babel-core \
  babel-loader \
  babel-preset-es2015 \
  eslint \
  eslint-config-airbnb \
  imports-loader \
  jasmine \

	// 1. Go to chrome://memory-redirect/
	// 2. Paste this script into the developer console

	(function(){
	var SERVER = 'http://localhost:4567/', // Post metrics to any server
	STRINGS = 'chrome://memory-redirect/strings.js',
	INTERVAL = 10e3,
	RE_INCLUDE = /./; // only include certain results, if you want.

	function getMemoryStats() {

	describe "#sortBy", ->

	it "sorts on simple props", ->
	sorted = [ {name: "bar"}, {name: "baz"}, {name: "foo"} ]
	unsorted = [ {name: "foo"}, {name: "bar"}, {name: "baz"} ]

	expect(unsorted.sort(sortBy("name"))).toEqual(sorted)

	it "sorts in nested objects", ->
	unsorted = [ {name: first: "foo"}, {name: first: "bar"}, {name: first: "baz"} ]

	toArray = (d) -> [].slice.call(d)

	currify = (fn, args, remaining)->

	if remaining < 1
	return fn.apply(null, args)

	->
	currify(fn, args.slice(0, fn.length - 1).concat(toArray(arguments)), remaining - arguments.length)

	sys = require "sys"
	exec = require("child_process").exec
	spawn = require("child_process").spawn
	browserify = require "browserify"
	watchify = require "watchify"
	coffee_react = require "coffee-reactify"
	gulp = require "gulp"
	jade = require "gulp-jade"
	plumber = require "gulp-plumber"
	reload = require "gulp-livereload"

	Model = require "lib/model"

	class Card extends Model

	defaults:
	name: ""
	value: ""

	transform: (name, value)->

	source "https://rubygems.org"

	gem "rack"
	gem "rack-proxy"