You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by da...@apache.org on 2022/12/14 07:32:23 UTC
[kafka] branch 3.3 updated: MINOR: Fix FetchFromFollowerIntegrationTest.testFetchFromFollowerWithRoll (#12987)
This is an automated email from the ASF dual-hosted git repository.
dajac pushed a commit to branch 3.3
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/3.3 by this push:
new 8d32c49fd50 MINOR: Fix FetchFromFollowerIntegrationTest.testFetchFromFollowerWithRoll (#12987)
8d32c49fd50 is described below
commit 8d32c49fd50434971532055801c1b38c859c105e
Author: Artem Livshits <84...@users.noreply.github.com>
AuthorDate: Tue Dec 13 23:30:15 2022 -0800
MINOR: Fix FetchFromFollowerIntegrationTest.testFetchFromFollowerWithRoll (#12987)
The test was added with a fix to KAFKA-14379, 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 <dj...@confluent.io>
---
.../integration/kafka/server/FetchFromFollowerIntegrationTest.scala | 1 +
1 file changed, 1 insertion(+)
diff --git a/core/src/test/scala/integration/kafka/server/FetchFromFollowerIntegrationTest.scala b/core/src/test/scala/integration/kafka/server/FetchFromFollowerIntegrationTest.scala
index e0d7b358786..822099f605b 100644
--- a/core/src/test/scala/integration/kafka/server/FetchFromFollowerIntegrationTest.scala
+++ b/core/src/test/scala/integration/kafka/server/FetchFromFollowerIntegrationTest.scala
@@ -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
}