We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent bf53e66 commit ebc3cd3Copy full SHA for ebc3cd3
1 file changed
core/src/main/java/kafka/server/share/SharePartitionManager.java
@@ -170,7 +170,7 @@ public SharePartitionManager(
170
long remoteFetchMaxWaitMs,
171
Persister persister,
172
ShareGroupConfigProvider configProvider,
173
- ShareGroupMetrics metrics,
+ ShareGroupMetrics shareGroupMetrics,
174
BrokerTopicStats brokerTopicStats,
175
Supplier<Boolean> shareGroupDlqEnableSupplier,
176
ShareGroupDLQManager shareGroupDLQManager
@@ -185,7 +185,7 @@ public SharePartitionManager(
185
remoteFetchMaxWaitMs,
186
persister,
187
configProvider,
188
- metrics,
+ shareGroupMetrics,
189
brokerTopicStats,
190
shareGroupDlqEnableSupplier,
191
shareGroupDLQManager
0 commit comments