Skip to content

Add Kafka Consumer Lag asynchronous client to improve the experience for the users #30

@omarsmak

Description

@omarsmak

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)

Metadata

Metadata

Assignees

No one assigned

    Labels

    enhancementNew feature or request

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions