[GitHub] [pulsar] congbobo184 commented on a diff in pull request #16617: [improve] [txn] [PIP-160] Make transactions work more efficiently by aggregation operation for transaction log and pending ack store

[GitBox <gi...@apache.org>]

congbobo184 commented on code in PR #16617:
URL: https://github.com/apache/pulsar/pull/16617#discussion_r921909255


##########
conf/broker.conf:
##########
@@ -1535,4 +1535,28 @@ managedLedgerMaxUnackedRangesToPersistInZooKeeper=-1
 
 # If enabled, the maximum "acknowledgment holes" will not be limited and "acknowledgment holes" are stored in
 # multiple entries.
-persistentUnackedRangesWithMultipleEntriesEnabled=false
\ No newline at end of file
+persistentUnackedRangesWithMultipleEntriesEnabled=false
+
+# Provide a mechanism allowing the Transaction Log Store to aggregate multiple records into a batched record and
+# persist into a single BK entry. This will make Pulsar transactions work more  efficiently, aka batched log.
+# see: https://github.com/apache/pulsar/issues/15370
+transactionLogBatchedWriteEnabled = false;
+# If enabled the feature that transaction log batch, this attribute means maximum log records count in a batch.
+transactionLogBatchedWriteMaxRecords= 512;
+# If enabled the feature that transaction log batch, this attribute means bytes size in a batch.
+transactionLogBatchedWriteMaxSize= 1024 * 1024 * 4;
+# If enabled the feature that transaction log batch, this attribute means maximum wait time(in millis) for the first
+# record in a batch
+transactionLogBatchedWriteMaxDelayInMillis= 1;
+# Provide a mechanism allowing the Pending Ack Store to aggregate multiple records into a batched record and persist
+# into a single BK entry. This will make Pulsar transactions work more efficiently, aka batched log.
+# see: https://github.com/apache/pulsar/issues/15370
+transactionPendingAckBatchedWriteEnabled = false;
+# If enabled the feature that transaction pending ack log batch, this attribute means maximum log records count in a
+# batch.
+transactionPendingAckBatchedWriteMaxRecords= 512;
+# If enabled the feature that transaction pending ack log batch, this attribute means bytes size in a batch.
+transactionPendingAckBatchedWriteMaxSize= 1024 * 1024 * 4;
+# If enabled the feature that transaction pending ack log batch, this attribute means maximum wait time(in millis) for
+# the first record in a batch.
+transactionPendingAckBatchedWriteMaxDelayInMillis= 1;

Review Comment:
   move to 
   under https://github.com/apache/pulsar/blob/cfabdf88ea14eae3cc7105080d2d7531539b40e2/conf/broker.conf#L1437



-- 
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: commits-unsubscribe@pulsar.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org