Hoang Ong hoangong

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)

Regular Expressions

Basic Syntax

/.../: Start and end regex delimiters
|: Alternation
(): Grouping

	#!/bin/sh

	# check for where the latest version of IDEA is installed
	IDEA=`ls -1d /Applications/IntelliJ\ * \| tail -n1`
	wd=`pwd`

	# were we given a directory?
	if [ -d "$1" ]; then
	# echo "checking for things in the working dir given"
	wd=`ls -1d "$1" \| head -n1`

	import java.math.BigInteger
	import java.security.spec.RSAPublicKeySpec
	import java.security.{KeyFactory, PublicKey}
	import java.util.Base64

	import akka.actor.ActorSystem
	import akka.event.LoggingAdapter
	import akka.http.scaladsl.Http
	import akka.http.scaladsl.model.HttpRequest
	import akka.http.scaladsl.model.headers.{Authorization, OAuth2BearerToken}