From b78807e05d0adcfc166e57f48c3d24310a99527a Mon Sep 17 00:00:00 2001
From: Andy Walker <walkeraj@gmail.com>
Date: Mon, 4 Jan 2021 20:41:50 -0500
Subject: [PATCH] check for nil producerspec first

---
 pulsar-function-go/pf/instance.go | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git a/pulsar-function-go/pf/instance.go b/pulsar-function-go/pf/instance.go
index 23ab09000d4f2..98744665aa2c7 100644
--- a/pulsar-function-go/pf/instance.go
+++ b/pulsar-function-go/pf/instance.go
@@ -222,11 +222,13 @@ func (gi *goInstance) getProducer(topicName string) (pulsar.Producer, error) {
 		gi.context.instanceConf.funcDetails.Name), gi.context.instanceConf.instanceID)
 
 	batchBuilderType := pulsar.DefaultBatchBuilder
-	batchBuilder := gi.context.instanceConf.funcDetails.Sink.ProducerSpec.BatchBuilder
 
-	if batchBuilder != "" {
-		if batchBuilder == "KEY_BASED" {
-			batchBuilderType = pulsar.KeyBasedBatchBuilder
+	if gi.context.instanceConf.funcDetails.Sink.ProducerSpec != nil {
+		batchBuilder := gi.context.instanceConf.funcDetails.Sink.ProducerSpec.BatchBuilder
+		if batchBuilder != "" {
+			if batchBuilder == "KEY_BASED" {
+				batchBuilderType = pulsar.KeyBasedBatchBuilder
+			}
 		}
 	}