@@ -223,10 +223,10 @@ private AsyncKafkaConsumer<String, String> newConsumerWithStreamRebalanceData(
223
223
new StringDeserializer (),
224
224
new StringDeserializer (),
225
225
time ,
226
- (a , b , c , d , e , f , g , h ) -> applicationEventHandler ,
227
- a -> backgroundEventReaper ,
228
- (a , b , c , d , e , f , g ) -> fetchCollector ,
229
- (a , b , c , d ) -> metadata ,
226
+ (logContext , time , applicationEventBlockingQueue , completableEventReaper , applicationEventProcessorSupplier , networkClientDelegateSupplier , requestManagersSupplier , asyncConsumerMetrics ) -> applicationEventHandler ,
227
+ logContext -> backgroundEventReaper ,
228
+ (logContext , consumerMetadata , subscriptionState , fetchConfig , deserializers , fetchMetricsManager , time ) -> fetchCollector ,
229
+ (consumerConfig , subscriptionState , logContext , clusterResourceListeners ) -> metadata ,
230
230
backgroundEventQueue ,
231
231
Optional .ofNullable (streamsRebalanceData )
232
232
);
@@ -238,10 +238,10 @@ private AsyncKafkaConsumer<String, String> newConsumer(ConsumerConfig config) {
238
238
new StringDeserializer (),
239
239
new StringDeserializer (),
240
240
time ,
241
- (a , b , c , d , e , f , g , h ) -> applicationEventHandler ,
242
- a -> backgroundEventReaper ,
243
- (a , b , c , d , e , f , g ) -> fetchCollector ,
244
- (a , b , c , d ) -> metadata ,
241
+ (logContext , time , applicationEventBlockingQueue , completableEventReaper , applicationEventProcessorSupplier , networkClientDelegateSupplier , requestManagersSupplier , asyncConsumerMetrics ) -> applicationEventHandler ,
242
+ logContext -> backgroundEventReaper ,
243
+ (logContext , consumerMetadata , subscriptionState , fetchConfig , deserializers , fetchMetricsManager , time ) -> fetchCollector ,
244
+ (consumerConfig , subscriptionState , logContext , clusterResourceListeners ) -> metadata ,
245
245
backgroundEventQueue ,
246
246
Optional .empty ()
247
247
);
0 commit comments