Skip to content

Instantly share code, notes, and snippets.

View RamSinha's full-sized avatar

RamSinha

1 follower · 16 following
View GitHub Profile
@RamSinha
RamSinha / how_to_reset_kafka_consumer_group_offset.md
Created June 9, 2019 06:16 — forked from marwei/how_to_reset_kafka_consumer_group_offset.md
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.

  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.

  1. Reset the consumer offset for a topic (preview)



  


  




    


          
    

      

        
        

          

              @RamSinha
          

          

            
                RamSinha
                / kafka-cheat-sheet.md
            
            

              Created
              May 27, 2019 10:37
                — forked from filipefigcorreia/kafka-cheat-sheet.md
            

              
                Apache Kafka Cheat Sheet
              
          

        

      

        

  

      

    
Kafka Topics


List existing topics


bin/kafka-topics.sh --zookeeper localhost:2181 --list


Purge a topic


bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic mytopic --config retention.ms=1000


... wait a minute ...


bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic mytopic --delete-config retention.ms



  


  




    


          
    

      

        
        

          

              @RamSinha
          

          

            
                RamSinha
                / tmux_cheatsheet.markdown
            
            

              Created
              January 20, 2018 10:30
                — forked from henrik/tmux_cheatsheet.markdown
            

              
                tmux cheatsheet
              
          

        

      

        

  

      

    
tmux cheatsheet


As configured in my dotfiles.


start new:


tmux



start new with session name: