Skip to content

Instantly share code, notes, and snippets.

View tranmanh90's full-sized avatar
🇻🇳
Focusing

Tran Manh tranmanh90

🇻🇳
Focusing
3 followers · 51 following
View GitHub Profile
@tranmanh90
tranmanh90 / elasticsearch.yml
Created April 3, 2020 06:08
##################### ElasticSearch Configuration Example #####################
# This file contains an overview of various configuration settings,
# targeted at operations staff. Application developers should
# consult the guide at <http://elasticsearch.org/guide>.
#
# The installation procedure is covered at
# <http://elasticsearch.org/guide/en/elasticsearch/reference/current/setup.html>.
#
# ElasticSearch comes with reasonable defaults for most settings,
@tranmanh90
tranmanh90 / how_to_reset_kafka_consumer_group_offset.md
Created April 1, 2020 17:42 — 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)



  


  




    


          
    

      

        
        

          

              @tranmanh90
          

          

            
                tranmanh90
                / KeycloakClientAuthExample.java
            
            

              Created
              October 30, 2019 19:31
                — forked from thomasdarimont/KeycloakClientAuthExample.java
            

              
                Retrieve and verify AccessToken with Keycloak Client.
              
          

        

      

        

  

    
    


        



  


  

        

          
          package de.tdlabs.keycloak.client;
        

        

          
          

        

        

          
          import com.fasterxml.jackson.databind.ObjectMapper;
        

        

          
          import org.keycloak.OAuth2Constants;
        

        

          
          import org.keycloak.RSATokenVerifier;
        

        

          
          import org.keycloak.admin.client.Keycloak;
        

        

          
          import org.keycloak.admin.client.KeycloakBuilder;
        

        

          
          import org.keycloak.common.VerificationException;
        

        

          
          import org.keycloak.jose.jws.JWSHeader;
        

        

          
          import org.keycloak.representations.AccessToken;
        

  





    


  




    


          
    

      

        
        

          

              @tranmanh90
          

          

            
                tranmanh90
                / KeycloakUtils.java
            
            

              Created
              October 30, 2019 16:01
                — forked from radutoev/KeycloakUtils.java
            

              
                Keycloak access token bean
              
          

        

      

        

  

    
    


        



  


  

        

          
          @Component
        

        

          
          public class KeycloakUtils {
        

        

          
              @Bean
        

        

          
              @Scope(scopeName = WebApplicationContext.SCOPE_REQUEST,
        

        

          
                      proxyMode = ScopedProxyMode.TARGET_CLASS)
        

        

          
              public AccessToken accessToken() {
        

        

          
                  HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder
        

        

          
                          .currentRequestAttributes())
        

        

          
                          .getRequest();
        

        

          
                  AccessToken accessToken = ((KeycloakPrincipal) ((KeycloakAuthenticationToken) request.getUserPrincipal()).getPrincipal())