MCPcopy
hub / github.com/IBM/sarama / NewFunctionalTestConfig

Function NewFunctionalTestConfig

functional_test.go:97–109  ·  view source on GitHub ↗

NewFunctionalTestConfig returns a config meant to be used by functional tests.

()

Source from the content-addressed store, hash-verified

95
96// NewFunctionalTestConfig returns a config meant to be used by functional tests.
97func NewFunctionalTestConfig() *Config {
98 config := NewConfig()
99 // config.Consumer.Retry.Backoff = 0
100 // config.Producer.Retry.Backoff = 0
101
102 // Always use the maximum Sarama-supported API versions.
103 config.Version = MaxVersion
104 // Enable API versions negotiation with brokers. This will reduce the maximum
105 // API versions Sarama uses to never exceed the broker's supported versions.
106 config.ApiVersionsRequest = true
107
108 return config
109}
110
111type testEnvironment struct {
112 ToxiproxyClient *toxiproxy.Client

Callers 15

produceMsgsFunction · 0.85
consumeMsgsFunction · 0.85
TestFuncProducingFunction · 0.85
TestFuncProducingGzipFunction · 0.85
TestFuncProducingSnappyFunction · 0.85
TestFuncProducingZstdFunction · 0.85

Calls 1

NewConfigFunction · 0.70

Tested by

no test coverage detected