Tristan Burch tburch

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)

	language: java

	env:
	global:
	- SONATYPE_USERNAME=yourusername
	- secure: "your encrypted SONATYPE_PASSWORD=pass"

	after_success:
	- python addServer.py
	- mvn clean deploy --settings ~/.m2/mySettings.xml

	import java.awt.Color;
	import java.awt.Graphics;
	import java.awt.image.BufferedImage;
	import java.io.File;
	import java.io.IOException;

	import javax.imageio.ImageIO;

	public class Pixelation
	{

	import java.awt.Color;
	import java.awt.Graphics;
	import java.awt.image.BufferedImage;
	import java.io.File;
	import java.io.IOException;

	import javax.imageio.ImageIO;

	public class Pixelate
	{

	#!/usr/bin/env ruby

	require 'socket'

	LISTEN_PORT = 55514
	DESTINATION_HOST = "logsN.papertrailapp.com"
	DESTINATION_PORT = XXXXX

	class SyslogRelay
	PARSER = /^(<\d+>\S+\s+\S+\s+\S+) (\S+) ([^:]+): (.*)$/