Skip to content

Commit

Permalink
adding more comments
Browse files Browse the repository at this point in the history
  • Loading branch information
JobseRyan committed Mar 18, 2024
1 parent c4fc6b1 commit 1181561
Showing 1 changed file with 4 additions and 3 deletions.
7 changes: 4 additions & 3 deletions core/src/main/scala/kafka/server/Observer.scala
Original file line number Diff line number Diff line change
Expand Up @@ -59,10 +59,11 @@ trait Observer extends Configurable {
def observeProduceRequest(requestContext: RequestContext, produceRequest: ProduceRequest): Unit

/**
* Hook to track the client library type so different client types can be compared
* Hook to track the client library type so different client types can be compared. This function is in the hot path
* of request-handling so all computations that are added to it need to be light
*
* @param isXinfraClient is this clientId a xinfra client
* @param clientId The clientId for this specific request
* @param isXinfraClient is this clientId a xinfra client
* @param clientId The clientId for this specific request
*/
def trackClientLibrary(isXinfraClient: Boolean, clientId: String): Unit

Expand Down

0 comments on commit 1181561

Please sign in to comment.