Skip to content

Commit 9b91abf

Browse files
authored
[chore][receiver/kafkametrics] Cleanup unused code (#43709)
<!--Ex. Fixing a bug - Describe the bug and how this fixes the issue. Ex. Adding a feature - Explain what this achieves.--> #### Description Remove unused test from code. Signed-off-by: Paulo Dias <[email protected]>
1 parent b06a904 commit 9b91abf

File tree

1 file changed

+0
-18
lines changed

1 file changed

+0
-18
lines changed

receiver/kafkametricsreceiver/broker_scraper_franz_test.go

Lines changed: 0 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -118,24 +118,6 @@ func TestBrokerScraperFranz_Start(t *testing.T) {
118118
require.NoError(t, s.Shutdown(t.Context()))
119119
}
120120

121-
// func TestBrokerScraperFranz_ScrapeHandlesClientError(t *testing.T) {
122-
// setFranzGo(t, true)
123-
124-
// // stub the ctor to fail
125-
// orig := newFranzAdminClient
126-
// t.Cleanup(func() { newFranzAdminClient = orig })
127-
// newFranzAdminClient = func(ctx context.Context, cfg configkafka.ClientConfig, lg *zap.Logger, opts ...kgo.Opt) (*kadm.Client, *kgo.Client, error) {
128-
// return nil, nil, errors.New("new franz admin failed")
129-
// }
130-
131-
// cfg := franzTestConfig(t)
132-
// s, err := createBrokerScraperFranz(t.Context(), cfg, receivertest.NewNopSettings(metadata.Type))
133-
// require.NoError(t, err)
134-
135-
// _, err = s.ScrapeMetrics(t.Context())
136-
// require.Error(t, err)
137-
// }
138-
139121
func TestBrokerScraperFranz_ShutdownWithoutStart_OK(t *testing.T) {
140122
setFranzGo(t, true)
141123

0 commit comments

Comments
 (0)