MINOR: Fix FetchFromFollowerIntegrationTest.testFetchFromFollowerWithRoll
The test was added with a fix to the problem was that the replication factor for the offset topic was 1 and consumer group coordinator got unavailable when one of the brokers got shut down.
Reviewers: David Jacot
@@ -42,6 +42,7 @@ class FetchFromFollowerIntegrationTest extends BaseFetchRequestTest {
def overridingProps: Properties = {
val props = new Properties
props.put(KafkaConfig.NumPartitionsProp, numParts.toString)
+ props.put(KafkaConfig.OffsetsTopicReplicationFactorProp, numNodes.toString)
props
}
