jlprat commented on code in PR #15279:
URL: https://github.com/apache/kafka/pull/15279#discussion_r1473118743
##########
core/src/main/scala/kafka/network/RequestChannel.scala:
##########
@@ -92,18 +92,18 @@ object RequestChannel extends Logging {
val envelope: Option[RequestChannel.Request] = None) extends
BaseRequest {
// These need to be volatile because the readers are in the network thread
and the writers are in the request
// handler threads or the purgatory threads
- @volatile var requestDequeueTimeNanos = -1L
- @volatile var apiLocalCompleteTimeNanos = -1L
- @volatile var responseCompleteTimeNanos = -1L
- @volatile var responseDequeueTimeNanos = -1L
- @volatile var messageConversionsTimeNanos = 0L
- @volatile var apiThrottleTimeMs = 0L
- @volatile var temporaryMemoryBytes = 0L
+ @volatile var requestDequeueTimeNanos: Long = -1L
+ @volatile var apiLocalCompleteTimeNanos: Long = -1L
+ @volatile var responseCompleteTimeNanos: Long = -1L
+ @volatile var responseDequeueTimeNanos: Long = -1L
+ @volatile var messageConversionsTimeNanos: Long = 0L
+ @volatile var apiThrottleTimeMs: Long = 0L
+ @volatile var temporaryMemoryBytes: Long = 0L
@volatile var recordNetworkThreadTimeCallback: Option[Long => Unit] = None
@volatile var callbackRequestDequeueTimeNanos: Option[Long] = None
@volatile var callbackRequestCompleteTimeNanos: Option[Long] = None
- val session = Session(context.principal, context.clientAddress)
+ val session: Session = Session(context.principal, context.clientAddress)
Review Comment:
I might have missed some spots where this should be applied but the Scala
idiomatic approach to this is:
- public API should be explicitly typed: this applies to `val`s, `var`s and
`def`s for example. Like the case you comment on.
- private definitions or variables don't need to be typed. Thanks to Scala
type inference many `def`s, `var`s and `val`s can omit their explicit type
making it easy to refactor things. Please note the "don't need to", you can
still explicitly type those.
Let me know if this answers your question.
--
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.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
