mumrah commented on code in PR #13033:
URL: https://github.com/apache/kafka/pull/13033#discussion_r1054483117
##########
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:
I'm guessing all of this logic will go away once we refactor the broker to
use MetadataLoader?
--
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
