Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
lucasbru committed Dec 17, 2024
1 parent d163f6e commit 7c77d19
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions core/src/test/scala/unit/kafka/server/RequestQuotaTest.scala
Original file line number Diff line number Diff line change
Expand Up @@ -739,6 +739,9 @@ class RequestQuotaTest extends BaseRequestTest {

case ApiKeys.READ_SHARE_GROUP_STATE_SUMMARY =>
new ReadShareGroupStateSummaryRequest.Builder(new ReadShareGroupStateSummaryRequestData(), true)

case ApiKeys.STREAMS_GROUP_HEARTBEAT =>
new StreamsGroupHeartbeatRequest.Builder(new StreamsGroupHeartbeatRequestData(), true)

case _ =>
throw new IllegalArgumentException("Unsupported API key " + apiKey)
Expand Down

0 comments on commit 7c77d19

Please sign in to comment.