cmccabe commented on code in PR #13033:
URL: https://github.com/apache/kafka/pull/13033#discussion_r1054777011
##########
core/src/main/scala/kafka/server/metadata/BrokerMetadataListener.scala:
##########
@@ -76,6 +77,21 @@ class BrokerMetadataListener(
*/
private var _highestTimestamp = -1L
+ /**
+ * The log epoch of the current transaction, or -1 if there is none.
+ */
+ private var _transactionEpoch = -1;
+
+ /**
+ * The log offset of the current transaction, or -1L if there is none.
+ */
+ private var _transactionOffset = -1L;
+
+ /**
+ * Pending records in the current transaction, or null if there is none such.
+ */
+ private var _transactionRecords: util.ArrayList[ApiMessageAndVersion] = _
+
Review Comment:
yeah, this file will be removed. but that's too ambitious for 3.4 I think
--
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
