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" |