David Alber davidalber

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)

	import { createCipheriv, createDecipheriv, randomBytes } from "crypto";

	const ENCRYPTION_KEY: string = process.env.ENCRYPTION_KEY \|\| ""; // Must be 256 bits (32 characters)
	const IV_LENGTH: number = 16; // For AES, this is always 16

	/**
	* Will generate valid encryption keys for use
	* Not used in the code below, but generate one and store it in ENV for your own purposes
	*/
	export function keyGen() {