Adesegun Adeyemo alexcrownus

## GCPAuthenticationInterceptor.java
package com.realkinetic.gcp.spring.oidc;

import com.auth0.jwt.JWT;
import com.auth0.jwt.algorithms.Algorithm;
import com.auth0.jwt.interfaces.DecodedJWT;
import com.google.api.client.http.*;
import com.google.api.client.http.javanet.NetHttpTransport;
import com.google.api.client.json.JsonObjectParser;
import com.google.api.client.json.jackson2.JacksonFactory;
import com.google.api.client.util.GenericData;

## how_to_reset_kafka_consumer_group_offset.md

      
              1 file
            
          
              0 forks
            
          
              0 comments
            
          
              0 stars
            
          
                alexcrownus
                / how_to_reset_kafka_consumer_group_offset.md
            
            
              Created
              March 11, 2023 02:41
                — 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.

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)


## GitConfigHttpProxy.md

      
              1 file
            
          
              0 forks
            
          
              0 comments
            
          
              0 stars
            
          
                alexcrownus
                / GitConfigHttpProxy.md
            
            
              Created
              February 8, 2023 15:40
                — forked from evantoli/GitConfigHttpProxy.md
            
              
                Configure Git to use a proxy
              
          
    Configure Git to use a proxy

In Brief

You may need to configure a proxy server if you're having trouble cloning
or fetching from a remote repository or getting an error
like unable to access '...' Couldn't resolve host '...'.
Consider something like:

  
## create_migration.sh
#!/bin/bash
echo "-- New Migration" > "`dirname $0`/../src/main/resources/db/migrations/V`date +%s`__$1.sql"

## sol-wallet
contract SimpleWallet {

	// address is the owner
	address owner;

	struct WithdrawlStruct {
		address to;
		uint amount;
	}

## gist:d4168a76f6a61501bd6749b18a7e58e6
package main

import (
	"bufio"
	"encoding/csv"
	"encoding/json"
	"fmt"
	"io"
	"os"
	"path/filepath"

## gist:9bd08400b4882f9e2ab1a2439460364f
// Worker represents the worker that executes the job
type Worker struct {
	JobChannel chan Job
	quit       chan bool
}

func NewWorker(jobChannel chan Job) Worker {
	return Worker{
		JobChannel: jobChannel,
		quit:       make(chan bool)}

## pool.go
package pool

type Task interface {
	Execute(id int)
}

type Pool struct {
	tasks chan Task
	kill  chan bool
}

## example.go
package main

const MaxLength = 1 << 20

var (
	addr     = flag.String("listen", ":8000", "listen for requests")
	numprocs = flag.Int("p", runtime.NumCPU(), "number of workers to start")
	maxqueue = flag.Int("q", runtime.NumCPU()*2, "largest queue size")

	jobs   chan Job

## golang_job_queue.md

      
              4 files
            
          
              0 forks
            
          
              0 comments
            
          
              0 stars
            
          
                alexcrownus
                / golang_job_queue.md
            
            
              Created
              January 9, 2017 01:21
                — forked from harlow/golang_job_queue.md
            
              
                Job queues in Golang
              
          
    Golang Job Queue

A running example of the code from:

http://marcio.io/2015/07/handling-1-million-requests-per-minute-with-golang
http://nesv.github.io/golang/2014/02/25/worker-queues-in-go.html

Step 1

Small refactorings made to original code:
	package com.realkinetic.gcp.spring.oidc;

	import com.auth0.jwt.JWT;
	import com.auth0.jwt.algorithms.Algorithm;
	import com.auth0.jwt.interfaces.DecodedJWT;
	import com.google.api.client.http.*;
	import com.google.api.client.http.javanet.NetHttpTransport;
	import com.google.api.client.json.JsonObjectParser;
	import com.google.api.client.json.jackson2.JacksonFactory;
	import com.google.api.client.util.GenericData;
	#!/bin/bash
	echo "-- New Migration" > "`dirname $0`/../src/main/resources/db/migrations/V`date +%s`__$1.sql"
	contract SimpleWallet {

	// address is the owner
	address owner;

	struct WithdrawlStruct {
	address to;
	uint amount;
	}
	package main

	import (
	"bufio"
	"encoding/csv"
	"encoding/json"
	"fmt"
	"io"
	"os"
	"path/filepath"
	// Worker represents the worker that executes the job
	type Worker struct {
	JobChannel chan Job
	quit chan bool
	}

	func NewWorker(jobChannel chan Job) Worker {
	return Worker{
	JobChannel: jobChannel,
	quit: make(chan bool)}
	package pool

	type Task interface {
	Execute(id int)
	}

	type Pool struct {
	tasks chan Task
	kill chan bool
	}
	package main

	const MaxLength = 1 << 20

	var (
	addr = flag.String("listen", ":8000", "listen for requests")
	numprocs = flag.Int("p", runtime.NumCPU(), "number of workers to start")
	maxqueue = flag.Int("q", runtime.NumCPU()*2, "largest queue size")

	jobs chan Job