diff --git a/main.go b/main.go
index 1a9b411..dbc2756 100644
--- a/main.go
+++ b/main.go
@@ -152,7 +152,8 @@
 			kafka.ProducerReturnOnErrors(true),
 			kafka.ProducerReturnOnSuccess(true),
 			kafka.ProducerMaxRetries(6),
-			kafka.ProducerRetryBackoff(time.Millisecond*30)), nil
+			kafka.ProducerRetryBackoff(time.Millisecond*30),
+			kafka.MetadatMaxRetries(15)), nil
 	}
 
 	return nil, errors.New("unsupported-client-type")