From 90abea5b7a6b78a88a6cedc7970462765900aec8 Mon Sep 17 00:00:00 2001
From: Klaus Post <klauspost@gmail.com>
Date: Thu, 18 Feb 2021 11:14:27 -0800
Subject: [PATCH] check if kafka producer is connected (#11578)

fixes #11576
---
 pkg/event/target/kafka.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/pkg/event/target/kafka.go b/pkg/event/target/kafka.go
index a900a26de..58aa4114d 100644
--- a/pkg/event/target/kafka.go
+++ b/pkg/event/target/kafka.go
@@ -160,6 +160,9 @@ func (target *KafkaTarget) Save(eventData event.Event) error {
 
 // send - sends an event to the kafka.
 func (target *KafkaTarget) send(eventData event.Event) error {
+	if target.producer == nil {
+		return errNotConnected
+	}
 	objectName, err := url.QueryUnescape(eventData.S3.Object.Key)
 	if err != nil {
 		return err