KAFKA-14032; Dequeue time for forwarded requests is unset (#12360)
When building a forwarded request, we need to override the dequeue time of the underlying request to match the same value as the envelope. Otherwise, the field is left unset, which causes inaccurate reporting. Reviewers; Jason Gustafson <jason@confluent.io>
显示
- core/src/main/scala/kafka/server/EnvelopeUtils.scala 4 个添加, 1 个删除core/src/main/scala/kafka/server/EnvelopeUtils.scala
- core/src/test/scala/unit/kafka/server/KafkaApisTest.scala 7 个添加, 3 个删除core/src/test/scala/unit/kafka/server/KafkaApisTest.scala
- core/src/test/scala/unit/kafka/utils/TestUtils.scala 4 个添加, 1 个删除core/src/test/scala/unit/kafka/utils/TestUtils.scala
加载中
想要评论请 注册 或 登录