Skip to content

Instantly share code, notes, and snippets.

Avatar

elakito

  • Heidelberg
View GitHub Profile
@elakito
elakito / sc_subtest.go
Created Dec 13, 2016
sarama_cluster's publisher subscriber samples to test partition assignment
View sc_subtest.go
package main
import (
"flag"
"fmt"
"log"
"strings"
"time"
"github.com/Shopify/sarama"