squah-confluent commented on code in PR #21334:
URL: https://github.com/apache/kafka/pull/21334#discussion_r2712872115
##########
core/src/main/scala/kafka/server/KafkaApis.scala:
##########
@@ -1792,8 +1791,7 @@ class KafkaApis(val requestChannel: RequestChannel,
marker.producerEpoch,
marker.coordinatorEpoch,
marker.transactionResult,
- markerTransactionVersion,
- Duration.ofMillis(config.requestTimeoutMs.toLong)
Review Comment:
With this change the timeout is reduced from a default of 30 seconds to a
default of 5 seconds. I have no objection to this.
We become inconsistent with the non-`__consumer_offsets` WriteTxnMarkers
timeout below but I think it's worth the simplicity.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
