Skip to content

Commit 0734325

Browse files
committed
Remove invalid configuration option
1 parent 9cb3f13 commit 0734325

File tree

1 file changed

+0
-1
lines changed

1 file changed

+0
-1
lines changed

mailer/kafka.go

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,6 @@ var _ Mailer = &KafkaMailer{}
3434
func NewKafkaMailer(cfg *KafkaMailerConfig, deliveryChan chan kafka.Event) (*KafkaMailer, error) {
3535
producer, err := kafka.NewProducer(&kafka.ConfigMap{
3636
"bootstrap.servers": cfg.GetBootstrapServers(),
37-
"auto.create.topics.enable": false,
3837
})
3938
if err != nil {
4039
return nil, err

0 commit comments

Comments
 (0)