Skip to content

Commit

Permalink
Shorten reload
Browse files Browse the repository at this point in the history
Signed-off-by: Marc Lopez Rubio <[email protected]>
  • Loading branch information
marclop committed Feb 25, 2025
1 parent e10d27a commit 0789c25
Showing 1 changed file with 1 addition and 3 deletions.
4 changes: 1 addition & 3 deletions kafka/common_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -665,7 +665,7 @@ func TestCertificateHotReloadErrors(t *testing.T) {
defer srv.Close()

// Create dialer with client certificate hot reloading
dialFunc, err := newCertReloadingDialer(caFile, certFile, keyFile, time.Millisecond*50, &tls.Config{})
dialFunc, err := newCertReloadingDialer(caFile, certFile, keyFile, time.Millisecond*10, &tls.Config{})
require.NoError(t, err)

// First connection should succeed
Expand All @@ -691,7 +691,6 @@ func TestCertificateHotReloadErrors(t *testing.T) {

// Restore valid certificate
require.NoError(t, os.WriteFile(certFile, clientCertPEM, 0644))
time.Sleep(100 * time.Millisecond)
})

t.Run("key_cert_mismatch", func(t *testing.T) {
Expand All @@ -710,7 +709,6 @@ func TestCertificateHotReloadErrors(t *testing.T) {

// Restore matching key and certificate
require.NoError(t, os.WriteFile(certFile, clientCertPEM, 0644))
time.Sleep(100 * time.Millisecond)
})
}

Expand Down

0 comments on commit 0789c25

Please sign in to comment.