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
   }