Streambed components for the commit log and secret store now manage their respective connections entirely, including an exponential backoff mechanism. Prior to this PR, only one function of the commit log managed the connection.
In addition, a new offsets method is provided to obtain the offsets given a topic and partition. Conforms to the Kafka REST API.
Streambed components for the commit log and secret store now manage their respective connections entirely, including an exponential backoff mechanism. Prior to this PR, only one function of the commit log managed the connection.
In addition, a new
offsets
method is provided to obtain the offsets given a topic and partition. Conforms to the Kafka REST API.