Reasno

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)

Reasno

/**
 * DowngradeRetryPolicy - This module is used to retry the READ / WRITE operation
 * by downgrading the value of consistency to minimum value.
 * @constructor
 */
function DowngradeRetryPolicy() {
}

// Inherit the retry policy 
util.inherits(DowngradeRetryPolicy, RetryPolicy);