谷溪 Reasno

## locks.go
package core_locks

import (
	"container/heap"
	"context"
	"errors"
	"fmt"
	"time"

	"github.com/go-redis/redis/v8"

## how_to_reset_kafka_consumer_group_offset.md

      
              1 file
            
          
              0 forks
            
          
              0 comments
            
          
              0 stars
            
          
                Reasno
                / how_to_reset_kafka_consumer_group_offset.md
            
            
              Created
              August 26, 2021 07:24
                — 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)


## kratosify.go
package util

import (
	"github.com/go-kit/kit/endpoint"
	"github.com/go-kratos/kratos/v2/middleware"
)

// Kratosify Converts a Go-Kit middleware to Kratos middleware
func Kratosify(kitmw endpoint.Middleware) middleware.Middleware {
	return func(handler middleware.Handler) middleware.Handler {

## commitlint.sh
#!/bin/sh

# set values from config file to variables
function set_config_values() {
  revert=false
  types=(build ci docs feat fix perf refactor style chore test)
  min_length=5
  max_length=52
}

## set-cookie.php
<?php
$server = new Swoole\WebSocket\Server("0.0.0.0", 9503);

$server->on('message', function () {
});

$server->on('handshake', function (\Swoole\Http\Request $request, \Swoole\Http\Response $response) {

    $secWebSocketKey = $request->header['sec-websocket-key'];
    $patten          = '#^[+/0-9A-Za-z]{21}[AQgw]==$#';

## delete all helm releases by a prefix
helm list --short | grep prefix | xargs -L1 helm delete --purge

## downgradeRetryPolicy.js
/**
 * DowngradeRetryPolicy - This module is used to retry the READ / WRITE operation
 * by downgrading the value of consistency to minimum value.
 * @constructor
 */
function DowngradeRetryPolicy() {
}

// Inherit the retry policy
util.inherits(DowngradeRetryPolicy, RetryPolicy);

## use aliyun images to replace google kubernete images
#!/bin/bash
set -o errexit
set -o nounset
set -o pipefail

KUBE_VERSION=v1.10.0
KUBE_PAUSE_VERSION=3.0
ETCD_VERSION=3.2.13
DNS_VERSION=1.14.8

## download kubernete images to aliyun
#!/bin/bash
set -o errexit
set -o nounset
set -o pipefail

KUBE_VERSION=v1.10.0
KUBE_PAUSE_VERSION=3.0
ETCD_VERSION=3.2.13
DNS_VERSION=1.14.8

## ComposeMinxins.php
function composeMixins(callable ...$mixins)
{
	return function(
		$x = [],
		callable $mix = null
	) use ($mixins){
		$mix = $mix ?? function(callable ...$fns) use ($x){
			return array_reduce($fns, function($acc, $fn){
				return call_user_func($fn, $acc);
			}, $x);
	package core_locks

	import (
	"container/heap"
	"context"
	"errors"
	"fmt"
	"time"

	"github.com/go-redis/redis/v8"
	package util

	import (
	"github.com/go-kit/kit/endpoint"
	"github.com/go-kratos/kratos/v2/middleware"
	)

	// Kratosify Converts a Go-Kit middleware to Kratos middleware
	func Kratosify(kitmw endpoint.Middleware) middleware.Middleware {
	return func(handler middleware.Handler) middleware.Handler {
	#!/bin/sh

	# set values from config file to variables
	function set_config_values() {
	revert=false
	types=(build ci docs feat fix perf refactor style chore test)
	min_length=5
	max_length=52
	}
	/**
	* DowngradeRetryPolicy - This module is used to retry the READ / WRITE operation
	* by downgrading the value of consistency to minimum value.
	* @constructor
	*/
	function DowngradeRetryPolicy() {
	}

	// Inherit the retry policy
	util.inherits(DowngradeRetryPolicy, RetryPolicy);
	#!/bin/bash
	set -o errexit
	set -o nounset
	set -o pipefail

	KUBE_VERSION=v1.10.0
	KUBE_PAUSE_VERSION=3.0
	ETCD_VERSION=3.2.13
	DNS_VERSION=1.14.8
	function composeMixins(callable ...$mixins)
	{
	return function(
	$x = [],
	callable $mix = null
	) use ($mixins){
	$mix = $mix ?? function(callable ...$fns) use ($x){
	return array_reduce($fns, function($acc, $fn){
	return call_user_func($fn, $acc);
	}, $x);