Skip to content

Commit f6a08ba

Browse files
committed
MINOR: Replaced internal KafkaConfig field in TransactionLogConfig
1 parent c527530 commit f6a08ba

File tree

1 file changed

+6
-4
lines changed

1 file changed

+6
-4
lines changed

Diff for: transaction-coordinator/src/main/java/org/apache/kafka/coordinator/transaction/TransactionLogConfig.java

+6-4
Original file line numberDiff line numberDiff line change
@@ -74,22 +74,24 @@ public final class TransactionLogConfig {
7474
// Configuration for testing only as default value should be sufficient for typical usage
7575
.defineInternal(PRODUCER_ID_EXPIRATION_CHECK_INTERVAL_MS_CONFIG, INT, PRODUCER_ID_EXPIRATION_CHECK_INTERVAL_MS_DEFAULT, atLeast(1), LOW, PRODUCER_ID_EXPIRATION_CHECK_INTERVAL_MS_DOC);
7676

77-
private final AbstractConfig config;
7877
private final int transactionTopicMinISR;
7978
private final int transactionLoadBufferSize;
8079
private final short transactionTopicReplicationFactor;
8180
private final int transactionTopicPartitions;
8281
private final int transactionTopicSegmentBytes;
8382
private final int producerIdExpirationCheckIntervalMs;
83+
private final boolean transactionPartitionVerificationEnable;
84+
private final int producerIdExpirationMs;
8485

8586
public TransactionLogConfig(AbstractConfig config) {
86-
this.config = config;
8787
this.transactionTopicMinISR = config.getInt(TRANSACTIONS_TOPIC_MIN_ISR_CONFIG);
8888
this.transactionLoadBufferSize = config.getInt(TRANSACTIONS_LOAD_BUFFER_SIZE_CONFIG);
8989
this.transactionTopicReplicationFactor = config.getShort(TRANSACTIONS_TOPIC_REPLICATION_FACTOR_CONFIG);
9090
this.transactionTopicPartitions = config.getInt(TRANSACTIONS_TOPIC_PARTITIONS_CONFIG);
9191
this.transactionTopicSegmentBytes = config.getInt(TRANSACTIONS_TOPIC_SEGMENT_BYTES_CONFIG);
9292
this.producerIdExpirationCheckIntervalMs = config.getInt(PRODUCER_ID_EXPIRATION_CHECK_INTERVAL_MS_CONFIG);
93+
this.transactionPartitionVerificationEnable = config.getBoolean(TRANSACTION_PARTITION_VERIFICATION_ENABLE_CONFIG);
94+
this.producerIdExpirationMs = config.getInt(PRODUCER_ID_EXPIRATION_MS_CONFIG);
9395
}
9496

9597
public int transactionTopicMinISR() {
@@ -118,11 +120,11 @@ public int producerIdExpirationCheckIntervalMs() {
118120

119121
// This is a broker dynamic config used for DynamicProducerStateManagerConfig
120122
public boolean transactionPartitionVerificationEnable() {
121-
return config.getBoolean(TRANSACTION_PARTITION_VERIFICATION_ENABLE_CONFIG);
123+
return transactionPartitionVerificationEnable;
122124
}
123125

124126
// This is a broker dynamic config used for DynamicProducerStateManagerConfig
125127
public int producerIdExpirationMs() {
126-
return config.getInt(PRODUCER_ID_EXPIRATION_MS_CONFIG);
128+
return producerIdExpirationMs;
127129
}
128130
}

0 commit comments

Comments
 (0)