diff --git a/flow/connectors/kafka/kafka.go b/flow/connectors/kafka/kafka.go index d02bb94ab7..30b370e51e 100644 --- a/flow/connectors/kafka/kafka.go +++ b/flow/connectors/kafka/kafka.go @@ -45,7 +45,7 @@ func NewKafkaConnector( kgo.SoftwareNameAndVersion("peerdb", peerdbenv.PeerDBVersionShaShort()), ) if !config.DisableTls { - optionalOpts = append(optionalOpts, kgo.DialTLSConfig(&tls.Config{MinVersion: tls.VersionTLS13})) + optionalOpts = append(optionalOpts, kgo.DialTLSConfig(&tls.Config{MinVersion: tls.VersionTLS12})) } switch config.Partitioner { case "LeastBackup":