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
+			}
 		}
 	}