Dear team,
I would like to propose the following improvement on the Kafka Health Check:
Have an option to test only bootstrap server connectivity to ensure connection parameters are good, like https://github.com/Brett1981/TempRepo/blob/4ab513b6138266530f10c2b65ebe32b1440f4621/Sage200Microservice.API/HealthChecks/KafkaConsumerLivenessHealthCheck.cs#L29. This implementation should also take into account authentication with OAuth.
The current implementation assumes the client is a producer and it doesn't verify the correct topic. Unfortunately, Confluence dotnet libraryt doesn't seem to have a way to improve on this or on how to check if a topic can be read by a consumer.
What are your thoughts on this?
Cheers
Dear team,
I would like to propose the following improvement on the Kafka Health Check:
Have an option to test only bootstrap server connectivity to ensure connection parameters are good, like https://github.com/Brett1981/TempRepo/blob/4ab513b6138266530f10c2b65ebe32b1440f4621/Sage200Microservice.API/HealthChecks/KafkaConsumerLivenessHealthCheck.cs#L29. This implementation should also take into account authentication with OAuth.
The current implementation assumes the client is a producer and it doesn't verify the correct topic. Unfortunately, Confluence dotnet libraryt doesn't seem to have a way to improve on this or on how to check if a topic can be read by a consumer.
What are your thoughts on this?
Cheers