We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e79bf2f commit 478179dCopy full SHA for 478179d
receiver/kafkareceiver/factory_test.go
@@ -28,9 +28,9 @@ func TestCreateDefaultConfig(t *testing.T) {
28
assert.Equal(t, defaultInitialOffset, cfg.InitialOffset)
29
assert.Equal(t, defaultSessionTimeout, cfg.SessionTimeout)
30
assert.Equal(t, defaultHeartbeatInterval, cfg.HeartbeatInterval)
31
- assert.Equal(t, int32(defaultMinFetchSize), cfg.MinFetchSize)
32
- assert.Equal(t, int32(defaultDefaultFetchSize), cfg.DefaultFetchSize)
33
- assert.Equal(t, int32(defaultMaxFetchSize), cfg.MaxFetchSize)
+ assert.Equal(t, defaultMinFetchSize, cfg.MinFetchSize)
+ assert.Equal(t, defaultDefaultFetchSize, cfg.DefaultFetchSize)
+ assert.Equal(t, defaultMaxFetchSize, cfg.MaxFetchSize)
34
}
35
36
func TestCreateTracesReceiver(t *testing.T) {
0 commit comments