NewFunctionalTestConfig returns a config meant to be used by functional tests.
()
| 95 | |
| 96 | // NewFunctionalTestConfig returns a config meant to be used by functional tests. |
| 97 | func 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 | |
| 111 | type testEnvironment struct { |
| 112 | ToxiproxyClient *toxiproxy.Client |
no test coverage detected