Skip to content

Instantly share code, notes, and snippets.

View maliqu's full-sized avatar

maliqu

View GitHub Profile
@maliqu
maliqu / how_to_reset_kafka_consumer_group_offset.md
Created January 24, 2018 14:02 — 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)



  


  




    


          
    

      

        
        

          

              @maliqu
          

          

            
                maliqu
                / check_docker_container.sh
            
            

              Created
              August 7, 2017 18:13
                — forked from ekristen/check_docker_container.sh
            

              
                Bash Script for Nagios to Check Status of Docker Container
              
          

        

      

        

  

    
    


        



  


  

        

          
          #!/bin/bash
        

        

          
          

        

        

          
          # Author: Erik Kristensen
        

        

          
          # Email: [email protected]
        

        

          
          # License: MIT
        

        

          
          # Nagios Usage: check_nrpe!check_docker_container!_container_id_
        

        

          
          # Usage: ./check_docker_container.sh _container_id_
        

        

          
          #
        

        

          
          # Depending on your docker configuration, root might be required. If your nrpe user has rights
        

        

          
          # to talk to the docker daemon, then root is not required. This is why root privileges are not