jolshan commented on code in PR #20882:
URL: https://github.com/apache/kafka/pull/20882#discussion_r2529131082
##########
core/src/main/scala/kafka/server/KafkaApis.scala:
##########
@@ -1780,6 +1782,8 @@ class KafkaApis(val requestChannel: RequestChannel,
}
val controlRecords = mutable.Map.empty[TopicIdPartition, MemoryRecords]
+ val markerTransactionVersion = marker.transactionVersion()
+
Review Comment:
Are we just saying the marker will have the non-bumped epoch in the logs
then? That's the only way I see this working.
Taking this to the extreme, we could also just not bump the epoch in the
request then?
--
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]
