Merge pull request #1117 from Shopify/require-version-for-headers

Add version check for headers
IBM · Jun 15, 2018 · f4466a0 · f4466a0
2 parents 6967cdb + 6d9cc20
commit f4466a0
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/async_producer.go b/async_producer.go
@@ -271,6 +271,9 @@ func (p *asyncProducer) dispatcher() {
 		version := 1
 		if p.conf.Version.IsAtLeast(V0_11_0_0) {
 			version = 2
+		} else if msg.Headers != nil {
+			p.returnError(msg, ConfigurationError("Producing headers requires Kafka at least v0.11"))
+			continue
 		}
 		if msg.byteSize(version) > p.conf.Producer.MaxMessageBytes {
 			p.returnError(msg, ErrMessageSizeTooLarge)