hachikuji commented on a change in pull request #9418:
URL: https://github.com/apache/kafka/pull/9418#discussion_r509615681
##########
File path: core/src/main/scala/kafka/tools/TestRaftRequestHandler.scala
##########
@@ -56,73 +47,8 @@ class TestRaftRequestHandler(
| ApiKeys.END_QUORUM_EPOCH
| ApiKeys.FETCH =>
val requestBody = request.body[AbstractRequest]
- networkChannel.postInboundRequest(
- request.header,
- requestBody,
- response => sendResponse(request, Some(response)))
-
- case ApiKeys.API_VERSIONS =>
Review comment:
I felt it was too difficult to approximate a controller workload using
one or more producers because of the fact that we can only handle one request
at a time. So I created a separate workload generator which executes on the
leader and I removed all of this somewhat hacky handling logic which allowed us
to use a producer.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
