Similar effort to the one in Spring for Apache Kafka, for example: https://github.com/spring-projects/spring-kafka/issues/4051