Add REST Endpoint for Health check etc in Kafka Connect app

Hi, I'd like to add a REST Endpoint for Health check in our Kafka Connect application. One way to do that is to implement ConnectRestExtension interface, but the problem is only ConnectRestExtensionContext will be passed in to the class, there is so few info contained in ConnectClusterState. Is

does Kafka exactly-once guarantee also apply to kafka state stores?

Hi All, We use Kafka streams and may need to use exactly-once configuration for some of the use cases. Currently, the application uses either local or global state store to store state. So, the application will consume events from source kafka topic, process the events, for state stores it will u