David Alber davidalber

## .block
license: gpl-3.0

## encryption.js
'use strict';

const crypto = require('crypto');

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

function encrypt(text) {
 let iv = crypto.randomBytes(IV_LENGTH);
 let cipher = crypto.createCipheriv('aes-256-cbc', Buffer.from(ENCRYPTION_KEY), iv);

## how_to_reset_kafka_consumer_group_offset.md

      
        
          
            
              
              1 file
            
          
          
            
              
              86 forks
            
          
          
            
              
              31 comments
            
          
          
            
              
              315 stars
            
          
        
        
          
              
          
          
            
                marwei
                / how_to_reset_kafka_consumer_group_offset.md
            
            
              Created
              November 9, 2017 23:39
            
              
                How to Reset Kafka Consumer Group Offset
              
          
        
      
        
  
      
    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)
	'use strict';

	const crypto = require('crypto');

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

	function encrypt(text) {
	let iv = crypto.randomBytes(IV_LENGTH);
	let cipher = crypto.createCipheriv('aes-256-cbc', Buffer.from(ENCRYPTION_KEY), iv);