You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
The current KafkaConsumerLagClient runs in a sync way which is as result, the user as well as the component need to poll the data on fixed interval. Since the Admin Client returns all the data in Future<T> based, would make sense to utilize that. Even expose the API as Flux<T>/Mono<T> async APIs which makes it easier for the user to work with the async APIs.
In order to not break any existing functionality, it would make sense to add a new Client interface that is dedicated for async APIs e.g: KafkaConsumerLagAsyncClient and from the factory to create the client KafkaConsumerLagClientFactory.createAsync(props)
The text was updated successfully, but these errors were encountered:
The current
KafkaConsumerLagClient
runs in a sync way which is as result, the user as well as the component need to poll the data on fixed interval. Since the Admin Client returns all the data inFuture<T>
based, would make sense to utilize that. Even expose the API asFlux<T>/Mono<T>
async APIs which makes it easier for the user to work with the async APIs.In order to not break any existing functionality, it would make sense to add a new Client interface that is dedicated for async APIs e.g:
KafkaConsumerLagAsyncClient
and from the factory to create the clientKafkaConsumerLagClientFactory.createAsync(props)
The text was updated successfully, but these errors were encountered: