check for nil producerspec first (apache#9124)

Fixes apache#9123 ### Modifications Check for nil ProducerSpec first ### Verifying this change as in apache#9123
sarvex · Jan 8, 2021 · 3b6fa26 · 3b6fa26
1 parent 7c09f5c
commit 3b6fa26
Showing 1 changed file with 6 additions and 4 deletions.
diff --git 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
+			}
 		}
 	}