kppullin

# Port of `kafka/core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala -> OffsetsMessageFormatter`
# `key` and `value` are the raw byte arrays from the `__consumer_offsets` topic.

import io
import struct

key_reader = io.BytesIO(key)
value_reader = io.BytesIO(value)
key_version = struct.unpack('>h', key_reader.read(2))[0]

kppullin

[package]
name = "actix-data--no-double-arc"
version = "0.1.0"
edition = "2018"

[dependencies]
actix-rt = "1.1.1"
actix-web = { version = "3.3.2" }
futures = "0.3.8"
tokio = { version = "0.2.24", features = ["macros"] }

kppullin

#
# This fish config sets up a working `gnome-keyring` on WSL2.
# I imagine it will work with WSL1 as well, perhaps after adjusting the `DISPLAY` value.
#
# Based off this bash script: https://askubuntu.com/questions/815327/running-gnome-keyring-on-wsl-windows-subsystem-for-linux
# Tested and working with `aws-vault` and `jetbrains-toolbox`.
#

# Be sure your x server is running!!!
set -x DISPLAY (cat /etc/resolv.conf | grep nameserver | awk '{print $2}'):0

kppullin

#!/usr/bin/env bash

# Overview:
# 1) Get list of all topic names
# 2) Iterate list, dumping each one to json

# Pre-reqs:
# 1) kafkacat
# 2) jq

kppullin

Overview

The steps below bootstrap an instance of airflow, configured to use the kubernetes airflow executor, working within a minikube cluster.

This guide works with the airflow 1.10 release, however will likely break or have unnecessary extra steps in future releases (based on recent changes to the k8s related files in the airflow source).

Prerequisites

• Docker installed
• Minikube installed and started

kppullin

Keybase proof

I hereby claim:

• I am kppullin on github.
• I am kppullin (https://keybase.io/kppullin) on keybase.
• I have a public key whose fingerprint is 79FB 133B E75F 0522 9015 E180 26C4 ED7F 265F 0846

To claim this, I am signing this object:

kppullin

var s = @"SELECT *
	FROM TABLE
	WHERE ID = @ID
";

var sb = new StringBuilder();

var lines = Regex.Split(s, "\n");
for (int i = 0; i < lines.Length; ++i)
{

kppullin

#!/bin/bash
#
# Create a swap partition equal to the system RAM
# on the first ephemeral disk.
#

function activate_swap_on_device {
  swap_on=`swapon -s | grep 'dev' | wc -l`
  if [[ ${swap_on} -gt 0 ]]; then
    echo "At least one swap partition is already active. Doing nothing (we assume zero or one only)"

kppullin

var edge = require('edge');
 
var testDynamic = edge.func(function() {/*
  //#r "System.Core.dll"
  //#r "Microsoft.CSharp.dll"
 
	using System.Dynamic;
	using System.Threading.Tasks;
 
	public class Startup

kppullin

public class JsonNetSerializer : ISerializer
{
	private Nancy.Responses.DefaultJsonSerializer _defaultSerializer = new Nancy.Responses.DefaultJsonSerializer();

	public bool CanSerialize(string contentType)
	{
		return _defaultSerializer.CanSerialize(contentType);
	}

	public void Serialize<TModel>(string contentType, TModel model, Stream outputStream)