[kafka] branch trunk updated: MINOR: Enable testUpdateFeaturesWithForwarding (#12059)

[sh...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

showuon pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 6f4778301b MINOR: Enable testUpdateFeaturesWithForwarding (#12059)
6f4778301b is described below

commit 6f4778301b1fcac1e2750cc697043d674eaa230d
Author: dengziming <de...@gmail.com>
AuthorDate: Wed Aug 31 15:06:21 2022 +0800

    MINOR: Enable testUpdateFeaturesWithForwarding (#12059)
    
    This test was removed in #11667 since UpdateFeatures is not properly handled in KRaft mode, now we can bring it back since UpdateFeatures is properly handled after #12036.
    
    Reviewers: Luke Chen <sh...@gmail.com>
---
 core/src/test/scala/unit/kafka/server/KafkaApisTest.scala | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/core/src/test/scala/unit/kafka/server/KafkaApisTest.scala b/core/src/test/scala/unit/kafka/server/KafkaApisTest.scala
index d176f369f8..dada6187be 100644
--- a/core/src/test/scala/unit/kafka/server/KafkaApisTest.scala
+++ b/core/src/test/scala/unit/kafka/server/KafkaApisTest.scala
@@ -923,6 +923,12 @@ class KafkaApisTest {
     testForwardableApi(ApiKeys.CREATE_PARTITIONS, requestBuilder)
   }
 
+  @Test
+  def testUpdateFeaturesWithForwarding(): Unit = {
+    val requestBuilder = new UpdateFeaturesRequest.Builder(new UpdateFeaturesRequestData())
+    testForwardableApi(ApiKeys.UPDATE_FEATURES, requestBuilder)
+  }
+
   @Test
   def testDeleteTopicsWithForwarding(): Unit = {
     val requestBuilder = new DeleteTopicsRequest.Builder(new DeleteTopicsRequestData())