Increasing kafkaa producer limit from 1MB(default) -> 8MB

Makefile

@@ -11,7 +11,7 @@ BENCHMARK = BenchmarkRAWInput
 TEST = TestRawListenerBench
 BIN_NAME = gor
 VERSION := DEV-$(shell date +%s)
-CUSTOM_TAGS := --tags "ngo$(if $(CUSTOM_BUILD_TAGS), $(CUSTOM_BUILD_TAGS),)"
+CUSTOM_TAGS := -buildvcs=false --tags "ngo$(if $(CUSTOM_BUILD_TAGS), $(CUSTOM_BUILD_TAGS),)"
 LDFLAGS = -ldflags "-X main.VERSION=$(VERSION) -extldflags \"-static\" -X main.DEMO=$(DEMO)"
 MAC_LDFLAGS = -ldflags "-X main.VERSION=$(VERSION) -X main.DEMO=$(DEMO)"
 DOCKER_FPM_CMD := docker run --rm -t -v `pwd`:/src -w /src fleetdm/fpm

README.md

@@ -22,6 +22,12 @@ Check [latest documentation](http://github.com/buger/goreplay/wiki).
 ## Installation
 Download the latest binary from https://github.com/buger/goreplay/releases or [compile by yourself](https://github.com/buger/goreplay/wiki/Compilation).
 
+### Building Locally
+To create a release compatible for linux distro
+```bash
+make release-bin-linux-amd64
+```
+
 ## Getting started
 
 The most basic setup will be `sudo ./gor --input-raw :8000 --output-stdout` which acts like tcpdump.

output_kafka.go

@@ -34,6 +34,7 @@ func NewKafkaOutput(_ string, config *OutputKafkaConfig, tlsConfig *KafkaTLSConf
 		c.Producer.RequiredAcks = sarama.WaitForLocal
 		c.Producer.Compression = sarama.CompressionSnappy
 		c.Producer.Flush.Frequency = KafkaOutputFrequency * time.Millisecond
+		c.Producer.MaxMessageBytes = 8 * 1024 * 1024 // 8 MB
 
 		brokerList := strings.Split(config.Host, ",")