Avoid deprecation warning for produce.offset.report with newer librdk…

…afka versions
confluentinc · Oct 24, 2018 · 460e8e4 · 460e8e4 · agis · Nov 7, 2019
1 parent 4f17205
commit 460e8e4
Showing 1 changed file with 7 additions and 4 deletions.
diff --git a/kafka/producer.go b/kafka/producer.go
@@ -414,10 +414,13 @@ func NewProducer(conf *ConfigMap) (*Producer, error) {
 	}
 	produceChannelSize := v.(int)
 
-	v, _ = confCopy.extract("{topic}.produce.offset.report", nil)
-	if v == nil {
-		// Enable offset reporting by default, unless overriden.
-		confCopy.SetKey("{topic}.produce.offset.report", true)
+	if int(C.rd_kafka_version()) < 0x01000000 {
+		// produce.offset.report is no longer used in librdkafka >= v1.0.0
+		v, _ = confCopy.extract("{topic}.produce.offset.report", nil)
+		if v == nil {
+			// Enable offset reporting by default, unless overriden.
+			confCopy.SetKey("{topic}.produce.offset.report", true)
+		}
 	}
 
 	// Convert ConfigMap to librdkafka conf_t